################################################################################
## LOAD PACKAGES
################################################################################

library(tidyverse)        # A collection of R packages for data manipulation and visualization (includes ggplot2, dplyr, etc.)
library(dplyr)            # For data manipulation (e.g., filtering, grouping, summarizing)
library(forcats)          # For working with factors (e.g., reordering, modifying levels)
library(stringr)          # For string manipulation (e.g., pattern matching, cleaning)
library(janitor)          # For data cleaning (e.g., cleaning column names)
library(data.table)       # For fast and efficient data manipulation, especially with large datasets
library(lubridate)        # For date-time manipulation and conversion
library(ggtext)           # For enhanced text rendering in ggplot (e.g., HTML/Markdown support)
library(ggimage)          # For adding images into ggplot2 plots (e.g., logos or icons)
library(grid)             # For customizing and combining graphical objects
library(cowplot)          # For combining ggplot figures and extracting legends
library(scales)           # For custom scales in ggplot2 (e.g., axis formatting)
library(factoextra)       # For visualizing multivariate analysis (PCA, clustering, etc.)
library(corrplot)         # For visualizing correlation matrices
library(broom)            # For converting model outputs into tidy data frames
library(psych)            # For psychometric and multivariate analysis (e.g., factor analysis, reliability)
library(EFAtools)         # For exploratory factor analysis and related tools
library(EFA.dimensions)   # For dimension estimation in exploratory factor analysis
library(GPArotation)      # For factor rotation methods (e.g., Varimax, Promax)
library(lavaan)           # For structural equation modeling (SEM), including CFA
library(semPlot)          # For visualizing SEM models
library(semptools)        # For customizing SEM diagrams and enhancing semPlot visuals
#remotes::install_version("mirt", version = "1.43") # Previous version of mirt needed
library(mirt)             # For multidimensional item response theory (IRT) modeling
library(forecast)         # For time series analysis and forecasting models (e.g., ARIMA)
library(vegan)            # For ecological and multivariate data analysis (e.g., ordination, diversity indices)
library(readxl)           # For reading Excel files (.xlsx and .xls formats)
library(writexl)          # For writing Excel files (.xlsx format)
#library(xlsx)             # For reading and writing older Excel files (.xls/.xlsx)
library(xtable)           # For creating LaTeX or HTML tables from data frames
library(gtools)           # Miscellaneous R programming tools (e.g., mixedSort, permutations)

################################################################################
## SET WORKING DIRECTORY
################################################################################

getwd()

#setwd() # Set working directory here

################################################################################
## LOAD DATA: CITIZENS' OPINIONS
################################################################################

# Load data

stemtest.wallonia.fr.df <- read.csv("stemtest_wallonia_fr_df.csv")

################################################################################
## FIND OUTLIERS (DURATION)
################################################################################

# Remove sessions lasting 70 seconds or less
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>% filter(duration > 70000)

# Check summary description of duration before removing outliers
stemtest.wallonia.fr.duration.w.outliers <- summary(stemtest.wallonia.fr.df$duration)

# Calculate Q1 (25th percentile) and Q3 (75th percentile) of duration
stemtest.wallonia.fr.q1 <- quantile(stemtest.wallonia.fr.df$duration, 0.25)
stemtest.wallonia.fr.q3 <- quantile(stemtest.wallonia.fr.df$duration, 0.75)

# Calculate the interquartile range (IQR)
irq.wallonia.fr <- stemtest.wallonia.fr.q3 - stemtest.wallonia.fr.q1

# Define lower and upper bounds for outliers (using 1.5 * IQR method)
lower.bound.wallonia.fr <- stemtest.wallonia.fr.q1 - 1.5 * irq.wallonia.fr
upper.bound.wallonia.fr <- stemtest.wallonia.fr.q3 + 1.5 * irq.wallonia.fr

# Identify outliers by checking if the duration is outside the defined bounds
stemtest.wallonia.fr.df$outlier <- stemtest.wallonia.fr.df$duration < lower.bound.wallonia.fr | stemtest.wallonia.fr.df$duration > upper.bound.wallonia.fr

# Show a summary of the outlier status (TRUE for outliers, FALSE for non-outliers)
table(stemtest.wallonia.fr.df$outlier)

# Drop rows that are outliers (outlier == FALSE)
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>% filter(outlier == "FALSE") 

# Check summary description of duration after removing outliers
stemtest.wallonia.fr.duration.wo.outliers <- summary(stemtest.wallonia.fr.df$duration)

# Remove sessions lasting less than 180 seconds
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>% filter(duration >= 180000)

###############################################################################
## PERCENTAGE OF BOOSTED ITEMS
################################################################################

# Load labels
labels.df <- read_excel("labels.xlsx", col_names = TRUE)

# Get columns ending in "_opinion"
boosted.cols <- grep("_boosted$", names(stemtest.wallonia.fr.df), value = TRUE)

# Subset the dataframe to only _opinion columns
stemtest.wallonia.fr.boosted.df <- stemtest.wallonia.fr.df[, boosted.cols]

# Reshape the boosted dataframe
stemtest.wallonia.fr.boosted.df.long <- stemtest.wallonia.fr.boosted.df %>%
  pivot_longer(
    cols = ends_with("_boosted"),
    names_to = "code_boosted",
    values_to = "boosted"
  ) %>%
  mutate(
    code = str_remove(code_boosted, "_boosted"),
    boosted_binary = ifelse(is.na(boosted), 0, as.integer(boosted))
  )

# Join with labels to get category
stemtest.wallonia.fr.boosted.df.merged <- stemtest.wallonia.fr.boosted.df.long %>%
  left_join(labels.df, by = "code")

# Calculate percentage of TRUE responses by category
stemtest.wallonia.fr.boosted.df.summary <- stemtest.wallonia.fr.boosted.df.merged %>%
  mutate(category = str_to_title(str_to_lower(abbr))) %>%  # Convert to lowercase, then title case
  group_by(category) %>%
  summarise(
    percent_true = mean(boosted_binary) * 100,
    n = n()
  ) %>%
  arrange(desc(percent_true))

# Create plot showing percentage of salient answers per issue category
# Save the plot as a high-resolution PNG
png("figs/wallonia_fr_boosted_by_category.png", units = "in", width = 7, height = 5, res = 300)

# Reorder categories by descending percent_true
stemtest.wallonia.fr.boosted.df.summary$category <- fct_reorder(
  stemtest.wallonia.fr.boosted.df.summary$category,
  stemtest.wallonia.fr.boosted.df.summary$percent_true,
  .desc = TRUE
)

# Create the plot
ggplot(stemtest.wallonia.fr.boosted.df.summary, aes(x = category, y = percent_true, fill = category)) +
  geom_bar(stat = "identity", color = "black", size = 0.2) +
  scale_fill_manual(values = c(
    "Crime" = "#42d4f4",
    "Culture" = "#f032e6",
    "Economy" = "#800000",
    "Education" = "#9A6324",
    "Environment" = "#3cb44b",
    "Ethics" = "#f58231",
    "Foreign" = "#ffe119",
    "Housing" = "#000075",
    "Immigration" = "#e6194B",
    "Mobility" = "#4363d8",
    "State" = "#911eb4",
    "Welfare" = "#bfef45"
  )) +
  theme_minimal() +
  labs(
    x = "Issue Category",
    y = "% Boosted Answers"
  ) +
  theme(
    axis.text.x = element_text(angle = 45, hjust = 1, size = 10),
    axis.text.y = element_text(size = 10),
    axis.title.x = element_blank(),
    axis.title.y = element_text(size = 11, margin = margin(r = 8)),
    plot.title = element_blank(),
    legend.position = "none"
  ) +
  geom_text(aes(label = sprintf("%.2f", percent_true)), vjust = -0.5, size = 3)

# Close the PNG device
dev.off()

# Total number of "TRUE"
stemtest.wallonia.fr.boosted <- sum(stemtest.wallonia.fr.boosted.df == "TRUE", na.rm = TRUE)

# Total number of responses in _boosted columns
stemtest.wallonia.fr.boosted.total <- nrow(stemtest.wallonia.fr.boosted.df) * ncol(stemtest.wallonia.fr.boosted.df)

# Percentages
stemtest.wallonia.fr.pct.boosted <- (stemtest.wallonia.fr.boosted / stemtest.wallonia.fr.boosted.total) * 100

# Print
stemtest.wallonia.fr.pct.boosted

# Average number of boosted statements per respondent
stemtest.wallonia.fr.avg.boosted <- mean(rowSums(stemtest.wallonia.fr.boosted.df == TRUE))
stemtest.wallonia.fr.avg.boosted

################################################################################
## PERCENTAGE OF EACH ANSWER CATEGORY
################################################################################

# Get columns ending in "_opinion"
opinion.cols <- grep("_opinion$", names(stemtest.wallonia.fr.df), value = TRUE)

# Subset the dataframe to only _opinion columns
stemtest.wallonia.fr.opinion.df <- stemtest.wallonia.fr.df[, opinion.cols]

# Total number of "undecided", "agree", and "disagree"
stemtest.wallonia.fr.skipped <- sum(stemtest.wallonia.fr.opinion.df == "undecided", na.rm = TRUE)
stemtest.wallonia.fr.agree <- sum(stemtest.wallonia.fr.opinion.df == "agree", na.rm = TRUE)
stemtest.wallonia.fr.disagree <- sum(stemtest.wallonia.fr.opinion.df == "disagree", na.rm = TRUE)

# Total number of responses in _opinion columns
stemtest.wallonia.fr.total <- nrow(stemtest.wallonia.fr.opinion.df) * ncol(stemtest.wallonia.fr.opinion.df)

# Percentages
stemtest.wallonia.fr.pct.skipped <- (stemtest.wallonia.fr.skipped / stemtest.wallonia.fr.total) * 100
stemtest.wallonia.fr.pct.agree <- (stemtest.wallonia.fr.agree / stemtest.wallonia.fr.total) * 100
stemtest.wallonia.fr.pct.disagree <- (stemtest.wallonia.fr.disagree / stemtest.wallonia.fr.total) * 100

# Print
stemtest.wallonia.fr.pct.skipped
stemtest.wallonia.fr.pct.agree
stemtest.wallonia.fr.pct.disagree

# Average number of boosted statements per respondent
stemtest.wallonia.fr.avg.skipped <- mean(rowSums(stemtest.wallonia.fr.opinion.df == "undecided"))
stemtest.wallonia.fr.avg.skipped

################################################################################
## PERCENTAGE OF SKIPPED ITEMS: GRAPH
################################################################################

# Load labels to rename the columns and rows of the correlation matrix
labels.df <- read_excel("labels.xlsx", col_names = TRUE)

# Step 1: Calculate proportion of "undecided"
undecided.proportions <- stemtest.wallonia.fr.df %>%
  select(all_of(opinion.cols)) %>%
  summarise(across(everything(), ~mean(. == "undecided", na.rm = TRUE))) %>%
  pivot_longer(cols = everything(), names_to = "variable", values_to = "undecided_proportion")

# Step 2: Extract item codes
undecided.proportions <- undecided.proportions %>%
  mutate(code = str_remove(variable, "_opinion"))

# Step 3: Join with labels.df
undecided.proportions <- undecided.proportions %>%
  left_join(labels.df, by = "code")

# Step 4: Format label as "COLORED new_column: rest of label"
undecided.proportions <- undecided.proportions %>%
  mutate(
    label_colored = paste0(
      "<span style='color:", colors, ";'><b>", toupper(abbr), "</b></span>. ", label
    )
  )

# Step 5: Create plot and save to file
png("figs/wallonia_fr_undecided_plot.png", units = "in", width = 10, height = 8, res = 300)

ggplot(undecided.proportions, aes(y = reorder(label_colored, -undecided_proportion), x = undecided_proportion)) +
  geom_col(fill = "grey40") +
  theme_minimal() +
  labs(
    y = NULL,                        # Remove y-axis title
    x = "Proportion of skipped items"     # Keep x-axis title
    # No plot title
  ) +
  theme(
    axis.text.y = element_markdown(size = 10.5),
    axis.text.x = element_text(size = 13),
    axis.title.x = element_text(margin = margin(t = 15, b = 5), size = 14),  # Larger margin above/below x axis title
    plot.title = element_blank()   # Remove plot title if any
  )

dev.off()

################################################################################
## PARTY ADVICE
################################################################################

# Set seed
set.seed(123)

# Clean the dataset by removing any rows with missing values and sample 100,000 rows randomly
stemtest.wallonia.fr.df.100k <- stemtest.wallonia.fr.df[complete.cases(stemtest.wallonia.fr.df), ][sample(100000), ]

# Create a new dataframe that excludes salience columns (columns containing "_boosted")
stemtest.wallonia.fr.df.opinion <- select(stemtest.wallonia.fr.df.100k, -contains("_boosted")) #remove salience columns

# Clean column names by removing "_opinion" from them for clarity
stemtest.wallonia.fr.df.opinion <- stemtest.wallonia.fr.df.opinion %>% 
  rename_with(~ str_remove(., "_opinion"), everything()) #clean column names (remove "_opinion" string)

# Add a new column to represent the variable as "Agreement"
stemtest.wallonia.fr.df.opinion$variable <- "Agreement" #create variable column

# Create a separate dataframe for the salience data (removing agreement columns)
stemtest.wallonia.fr.df.boosted <- select(stemtest.wallonia.fr.df.100k, -contains("_opinion")) #remove agreement columns

# Clean column names by removing "_boosted" to make them clearer
stemtest.wallonia.fr.df.boosted <- stemtest.wallonia.fr.df.boosted %>% 
  rename_with(~ str_remove(., "_boosted"), everything()) #clean column names (remove "_boosted" string)

# Add a new column to represent the variable as "Salience"
stemtest.wallonia.fr.df.boosted$variable <- "Salience" #create variable column

# Combine the two dataframes (agreement and salience) into one
stemtest.wallonia.fr.df.both <- rbind(stemtest.wallonia.fr.df.opinion, stemtest.wallonia.fr.df.boosted)

# Save the combined dataframe to a file for future use
saveRDS(stemtest.wallonia.fr.df.both, "files/stemtest_wallonia_fr_df_both.rds")

# Transform the dataframe to long format, gathering specific columns into two key variables: 'code' and 'value'
stemtest.wallonia.fr.df.long <- tidyr::pivot_longer(
  stemtest.wallonia.fr.df.both,
  cols = dplyr::starts_with("ST"),
  names_to = "code",
  values_to = "value",
  names_transform = list(code = as.factor)
)

# Select only necessary columns from the long format dataframe
stemtest.wallonia.fr.df.long <- stemtest.wallonia.fr.df.long %>%
  dplyr::select(id, code, variable, value)

# Define the column types for 'code', 'variable', and 'value'
stemtest.wallonia.fr.df.long$code <- as.factor(stemtest.wallonia.fr.df.long$code)
stemtest.wallonia.fr.df.long$variable <- as.factor(stemtest.wallonia.fr.df.long$variable)
stemtest.wallonia.fr.df.long$value <- as.factor(stemtest.wallonia.fr.df.long$value)

# Remove rows where the 'value' column is empty or contains an empty string
stemtest.wallonia.fr.df.long <- subset(stemtest.wallonia.fr.df.long, value != "")

# Load external data (merged dataframe) and rename the column 'SID' to 'code' to match with the other dataframe
wallonia.fr.merge <- readRDS("wallonia_merge.rds")
wallonia.fr.merge <- rename(wallonia.fr.merge, c('code'='SID'))

# Merge the two dataframes (stemtest data and external merged data) based on the 'code' column
stemtest.wallonia.fr.df.long <- merge(stemtest.wallonia.fr.df.long, wallonia.fr.merge, by="code") #merge by statement code

# Convert columns from 'Defi_position' to 'PTB_position' to numeric
stemtest.wallonia.fr.df.long <- stemtest.wallonia.fr.df.long %>% 
  mutate(across(Defi_position:PTB_position, as.numeric))

# Create a new column 'agree' initialized as NA (missing values)
stemtest.wallonia.fr.df.long$agree <- NA

# Assign numeric values based on the 'value' column ('agree', 'disagree', 'undecided')
stemtest.wallonia.fr.df.long$agree[stemtest.wallonia.fr.df.long$value=="agree"] <- 1
stemtest.wallonia.fr.df.long$agree[stemtest.wallonia.fr.df.long$value=="disagree"] <- 2
stemtest.wallonia.fr.df.long$agree[stemtest.wallonia.fr.df.long$value=="undecided"] <- 0

# Assign 0 or 1 to the 'agree' column based on boolean values (TRUE/FALSE)
stemtest.wallonia.fr.df.long$agree[stemtest.wallonia.fr.df.long$value=="FALSE"] <- 0
stemtest.wallonia.fr.df.long$agree[stemtest.wallonia.fr.df.long$value=="TRUE"] <- 1

# Filter the data for salience rows (where variable is 'Salience')
stemtest.wallonia.fr.df.long.1 <- stemtest.wallonia.fr.df.long %>% 
  filter(variable == "Salience") 

# Filter the data for agreement rows (where variable is 'Agreement') and select only relevant columns
stemtest.wallonia.fr.df.long.2 <- stemtest.wallonia.fr.df.long %>% 
  filter(variable=="Agreement") %>% subset(select = c("id","code","agree"))

# Combine the two dataframes (salience and agreement) based on common 'id' and 'code' columns
stemtest.wallonia.fr.df.long <- stemtest.wallonia.fr.df.long.1 %>% 
  right_join(stemtest.wallonia.fr.df.long.2, by=c("id","code"))

# Rename columns to avoid name conflicts after joining
stemtest.wallonia.fr.df.long <- rename(stemtest.wallonia.fr.df.long, c('boosted'='agree.x',
                                                                     'agree'='agree.y'))

# Create a new dataframe with scores by summing the 'boosted' values for each 'id'
stemtest.scores.wallonia.fr <- stemtest.wallonia.fr.df.long %>% 
  group_by(id) %>% 
  mutate(sum_boosted = sum(boosted)) %>%
  ungroup()

stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>%
  mutate(Defi_score = case_when(agree==Defi_position & boosted==1 ~ stemtest.scores.wallonia.fr$DEFI + 20/stemtest.scores.wallonia.fr$sum_boosted,
                                agree==Defi_position & boosted==0 ~ stemtest.scores.wallonia.fr$DEFI + 0,
                                agree!=Defi_position ~ 0))

stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>%
  mutate(Ecolo_score = case_when(agree==Ecolo_position & boosted==1 ~ stemtest.scores.wallonia.fr$ECOLO + 20/stemtest.scores.wallonia.fr$sum_boosted,
                                 agree==Ecolo_position & boosted==0 ~ stemtest.scores.wallonia.fr$ECOLO + 0,
                                 agree!=Ecolo_position ~ 0))

stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>%
  mutate(LesEngages_score = case_when(agree==LesEngages_position & boosted==1 ~ stemtest.scores.wallonia.fr$LESENGAGES + 20/stemtest.scores.wallonia.fr$sum_boosted,
                                      agree==LesEngages_position & boosted==0 ~ stemtest.scores.wallonia.fr$LESENGAGES + 0,
                                      agree!=LesEngages_position ~ 0))

stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>%
  mutate(MR_score = case_when(agree==MR_position & boosted==1 ~ stemtest.scores.wallonia.fr$MR + 20/stemtest.scores.wallonia.fr$sum_boosted,
                              agree==MR_position & boosted==0 ~ stemtest.scores.wallonia.fr$MR + 0,
                              agree!=MR_position ~ 0))

stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>%
  mutate(PS_score = case_when(agree==PS_position & boosted==1 ~ stemtest.scores.wallonia.fr$PS + 20/stemtest.scores.wallonia.fr$sum_boosted,
                              agree==PS_position & boosted==0 ~ stemtest.scores.wallonia.fr$PS + 0,
                              agree!=PS_position ~ 0))

stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>%
  mutate(PTB_score = case_when(agree==PTB_position & boosted==1 ~ stemtest.scores.wallonia.fr$PTB + 20/stemtest.scores.wallonia.fr$sum_boosted,
                               agree==PTB_position & boosted==0 ~ stemtest.scores.wallonia.fr$PTB + 0,
                               agree!=PTB_position ~ 0))

# Group by 'id' and sum the scores for each position
stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>%
  group_by(id) %>% 
  mutate(across(Defi_score:PTB_score, sum)) %>%
  ungroup()

# Remove duplicate rows based on 'id' column while keeping the first occurrence
stemtest.scores.wallonia.fr <- distinct(stemtest.scores.wallonia.fr, id, .keep_all = TRUE)

# Rescale the scores by dividing by the sum of boosted responses and scaling to a percentage
stemtest.scores.wallonia.fr$Defi_rescaled <- (stemtest.scores.wallonia.fr$Defi_score/(100 + stemtest.scores.wallonia.fr$sum_boosted))*100
stemtest.scores.wallonia.fr$Ecolo_rescaled <- (stemtest.scores.wallonia.fr$Ecolo_score/(100 + stemtest.scores.wallonia.fr$sum_boosted))*100
stemtest.scores.wallonia.fr$LesEngages_rescaled <- (stemtest.scores.wallonia.fr$LesEngages_score/(100 + stemtest.scores.wallonia.fr$sum_boosted))*100
stemtest.scores.wallonia.fr$MR_rescaled <- (stemtest.scores.wallonia.fr$MR_score/(100 + stemtest.scores.wallonia.fr$sum_boosted))*100
stemtest.scores.wallonia.fr$PS_rescaled <- (stemtest.scores.wallonia.fr$PS_score/(100 + stemtest.scores.wallonia.fr$sum_boosted))*100
stemtest.scores.wallonia.fr$PTB_rescaled <- (stemtest.scores.wallonia.fr$PTB_score/(100 + stemtest.scores.wallonia.fr$sum_boosted))*100

# Identify the rescaled columns
stemtest.rescaled.cols.wallonia.fr <- grep("_rescaled", colnames(stemtest.scores.wallonia.fr), value = TRUE)

# For each row, find the column with the maximum rescaled value and assign the political position to 'advice'
stemtest.advice.wallonia.fr <- stemtest.rescaled.cols.wallonia.fr[
  apply(stemtest.scores.wallonia.fr[, stemtest.rescaled.cols.wallonia.fr], 1, which.max)
]

# Assign the best advice (political position) to each row in the 'advice' column
stemtest.scores.wallonia.fr$advice <- stemtest.advice.wallonia.fr

# Clean the 'advice' column by removing the suffix (e.g., "Defi_rescaled" becomes "Defi")
stemtest.scores.wallonia.fr$advice <- sub("_.*", "", stemtest.scores.wallonia.fr$advice)

# Select only relevant columns
stemtest.scores.wallonia.fr <- stemtest.scores.wallonia.fr %>% subset(select = c("id","advice"))

# Merge party advice to wide dataframe
stemtest.wallonia.fr.df.opinion <- merge(stemtest.wallonia.fr.df.opinion, stemtest.scores.wallonia.fr, by="id") 

# Recode opinion values ("agree" = 1, "disagree" = 0, "undecided" = NA)
stemtest.wallonia.fr.df.opinion <- stemtest.wallonia.fr.df.opinion %>%
  mutate(across(starts_with("ST"), ~ recode(.x, "agree" = "1", "disagree" = "0", "undecided" = "")))

# Identify policy item columns (those starting with "ST")
stemtest.wallonia.fr.policy.cols <- names(stemtest.wallonia.fr.df.opinion)[grepl("^ST", names(stemtest.wallonia.fr.df.opinion))]

# Convert all ST columns to numeric (in case they are factors or characters)
stemtest.wallonia.fr.df.opinion[stemtest.wallonia.fr.policy.cols] <- lapply(
  stemtest.wallonia.fr.df.opinion[stemtest.wallonia.fr.policy.cols],
  function(x) as.numeric(as.character(x))
)

# Function to compute mean absolute tetrachoric correlation
avg_function <- function(data) {
  cor_matrix <- tetrachoric(data[, stemtest.wallonia.fr.policy.cols])$rho
  upper_vals <- cor_matrix[upper.tri(cor_matrix)]
  mean(abs(upper_vals), na.rm = TRUE)  # Take the absolute values before averaging
}

# Group by 'advice' (party) and compute mean absolute tetrachoric correlation
stemtest.wallonia.fr.avg.byparty <- stemtest.wallonia.fr.df.opinion %>%
  group_by(advice) %>%
  summarise(avg_abs_tetra = avg_function(cur_data_all()))

# Show the result
print(stemtest.wallonia.fr.avg.byparty)

################################################################################
## CREATE PERSON WEIGHT
################################################################################

# Step 1: Identify opinion and boosted columns
stemtest.wallonia.fr.df.opinion.cols <- grep("_opinion$", names(stemtest.wallonia.fr.df), value = TRUE)
stemtest.wallonia.fr.df.boosted.cols <- gsub("_opinion$", "_boosted", stemtest.wallonia.fr.df.opinion.cols)

# Recode opinion values ("agree" = 1, "disagree" = 0, "undecided" = NA)
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>%
  mutate(across(ends_with("_opinion"), ~ recode(.x, "agree" = "1", "disagree" = "0", "undecided" = "")))

# Compute person-level weights
stemtest.wallonia.fr.boosted.matrix <- stemtest.wallonia.fr.df[, stemtest.wallonia.fr.df.boosted.cols]
stemtest.wallonia.fr.boosted.matrix[] <- lapply(stemtest.wallonia.fr.boosted.matrix, as.logical)
stemtest.wallonia.fr.boosted.matrix <- as.data.frame(lapply(stemtest.wallonia.fr.boosted.matrix, unlist))
stemtest.wallonia.fr.weight.matrix <- ifelse(as.matrix(stemtest.wallonia.fr.boosted.matrix), 2, 1)
person_weights <- rowSums(stemtest.wallonia.fr.weight.matrix)
person_weights <- person_weights / mean(person_weights)

stemtest.wallonia.fr.df$person_weights <- person_weights

################################################################################
## CREATE MAIN DATAFRAME FOR CITIZENS' OPINIONS
################################################################################

# Remove columns containing "_boosted" (such as salience-related columns)
stemtest.wallonia.fr.df <- select(stemtest.wallonia.fr.df, -contains("_boosted"))

# Clean column names by removing "_opinion" from all column names
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>% 
  rename_with(~ str_remove(., "_opinion"), everything())

# Convert opinion columns to numeric format
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>% 
  mutate(across(starts_with("ST"), as.numeric))

# Keep only the opinion columns, weights, duration, and date
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>% 
  select(starts_with('ST'), person_weights, duration, date)

# Remove columns that have only NA values
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df[, colSums(is.na(stemtest.wallonia.fr.df)) != nrow(stemtest.wallonia.fr.df)]

# Keep only complete cases (rows with no missing values)
#stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df[complete.cases(stemtest.wallonia.fr.df), ]

# Create copy of dataframe including weight column
stemtest.wallonia.fr.df.wgt <- stemtest.wallonia.fr.df %>% 
  select(starts_with('ST'), person_weights)

# Select only the opinion columns for further analysis
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df %>% 
  select(starts_with('ST'))

################################################################################
## COMPUTE CORRELATIONS BY ISSUE CATEGORY
################################################################################

wallonia.themes.fr.df <- stemtest.wallonia.fr.df
wallonia.themes.fr.df <- na.omit(wallonia.themes.fr.df)

# Load the Excel file containing the 'code' and 'abbr' columns
themes.data <- read_excel("labels.xlsx")  

# themes.data has columns 'code' (e.g., ST1, ST2, ...) and 'abbr' (e.g., ECONOMY, EDUCATION)
# Create a mapping of the code to the abbr (theme)
wallonia.fr.theme.map <- setNames(themes.data$abbr, themes.data$code)

# R dataframe 'wallonia.themes.fr.df' contains columns like ST1, ST2, ..., ST348
# Rename the columns in the dataframe based on the wallonia.fr.theme.map
colnames(wallonia.themes.fr.df) <- sapply(colnames(wallonia.themes.fr.df), function(colname) {
  # Check if the column name is in the wallonia.fr.theme.map and modify accordingly
  if (colname %in% names(wallonia.fr.theme.map)) {
    return(paste(wallonia.fr.theme.map[colname], colname, sep = "_"))
  } else {
    return(colname)  # In case there is no theme for that particular code
  }
})

# Step 1: Identify unique prefixes (everything before "_")
wallonia.fr.prefixes <- unique(substring(names(wallonia.themes.fr.df), 1, regexpr("_", names(wallonia.themes.fr.df)) - 1))

# Step 2: Compute tetrachoric correlations for columns with the same prefix
for (prefix in wallonia.fr.prefixes) {
  # Step 2a: Subset the dataframe to include only columns with the same prefix
  wallonia.fr.cols.with.prefix <- grep(paste0("^", prefix, "_"), names(wallonia.themes.fr.df), value = TRUE)
  
  # If there are fewer than 2 columns, skip the calculation for this prefix
  if (length(wallonia.fr.cols.with.prefix) < 2) {
    cat("\nSkipping prefix", prefix, "because it has fewer than 2 columns.\n")
    next  # Skip to the next prefix
  }
  
  # Subset the dataframe
  wallonia.themes.fr.df.subset <- wallonia.themes.fr.df[, wallonia.fr.cols.with.prefix]
  
  # Step 2b: Compute the tetrachoric correlation for the subset of columns
  wallonia.fr.tetra.cor <- tetrachoric(wallonia.themes.fr.df.subset)
  
  # Get the correlation matrix (rho)
  wallonia.fr.corr.matrix <- wallonia.fr.tetra.cor$rho
  
  # Step 3: Compute the absolute correlation matrix
  wallonia.fr.abs.corr.matrix <- abs(wallonia.fr.corr.matrix)  # Get the absolute values of the correlation matrix
  
  # Remove diagonal values (1s)
  diag(wallonia.fr.abs.corr.matrix) <- NA
  
  # Step 4: Compute the average absolute correlation for this set of columns
  wallonia.fr.avg.abs.corr.matrix <- mean(wallonia.fr.abs.corr.matrix, na.rm = TRUE)
  
  # Step 5: Adjust the average correlation by the number of variables (columns)
  N <- length(wallonia.fr.cols.with.prefix)  # Number of variables (columns)
  wallonia.fr.avg.adj.corr <- wallonia.fr.avg.abs.corr.matrix / (N - 1)  # Adjust by N - 1 (for pairwise correlation)
  
  # Step 6: Apply Fisher Z-transformation to the absolute correlation matrix
  wallonia.fr.abs.corr.matrix <- abs(wallonia.fr.corr.matrix)  # Take absolute values of correlations first
  wallonia.fr.fisher.z.matrix <- 0.5 * log((1 + wallonia.fr.abs.corr.matrix) / (1 - wallonia.fr.abs.corr.matrix))
  
  # Step 7: Compute the average Fisher Z-transformed correlation (excluding diagonal)
  wallonia.fr.fisher.z.matrix[lower.tri(wallonia.fr.fisher.z.matrix)] <- NA  # Optional: Set lower triangle to NA to avoid duplicates
  diag(wallonia.fr.fisher.z.matrix) <- NA  # Remove diagonal values
  wallonia.fr.avg.fisher.z <- mean(wallonia.fr.fisher.z.matrix, na.rm = TRUE)
  
  # Step 8: Reverse Fisher Z-transformation to get back to the original correlation scale
  wallonia.fr.avg.fisher.corr <- (exp(2 * wallonia.fr.avg.fisher.z) - 1) / (exp(2 * wallonia.fr.avg.fisher.z) + 1)
  
  # Print the results: Average, Adjusted Average, and Fisher Z-transformed Average correlation
  cat("\nFor prefix", prefix, ":\n")
  cat("  Average absolute correlation: ", wallonia.fr.avg.abs.corr.matrix, "\n")
  cat("  Adjusted average absolute correlation: ", wallonia.fr.avg.adj.corr, "\n")
  cat("  Fisher Z-transformed average correlation (absolute): ", wallonia.fr.avg.fisher.corr, "\n")
}

# Same but save in dataframe
# Initialize list to collect results
wallonia.fr.correlation.results <- list()

for (prefix in wallonia.fr.prefixes) {
  wallonia.fr.cols.with.prefix <- grep(paste0("^", prefix, "_"), names(wallonia.themes.fr.df), value = TRUE)
  
  if (length(wallonia.fr.cols.with.prefix) < 2) {
    cat("\nSkipping prefix", prefix, "because it has fewer than 2 columns.\n")
    next
  }
  
  wallonia.themes.fr.df.subset <- wallonia.themes.fr.df[, wallonia.fr.cols.with.prefix]
  wallonia.fr.tetra.cor <- tetrachoric(wallonia.themes.fr.df.subset)
  wallonia.fr.corr.matrix <- wallonia.fr.tetra.cor$rho
  
  wallonia.fr.abs.corr.matrix <- abs(wallonia.fr.corr.matrix)
  diag(wallonia.fr.abs.corr.matrix) <- NA
  wallonia.fr.avg.abs.corr.matrix <- mean(wallonia.fr.abs.corr.matrix, na.rm = TRUE)
  N <- length(wallonia.fr.cols.with.prefix)
  wallonia.fr.avg.adj.corr <- wallonia.fr.avg.abs.corr.matrix / (N - 1)
  
  wallonia.fr.fisher.z.matrix <- 0.5 * log((1 + wallonia.fr.abs.corr.matrix) / (1 - wallonia.fr.abs.corr.matrix))
  wallonia.fr.fisher.z.matrix[lower.tri(wallonia.fr.fisher.z.matrix)] <- NA
  diag(wallonia.fr.fisher.z.matrix) <- NA
  wallonia.fr.avg.fisher.z <- mean(wallonia.fr.fisher.z.matrix, na.rm = TRUE)
  wallonia.fr.avg.fisher.corr <- (exp(2 * wallonia.fr.avg.fisher.z) - 1) / (exp(2 * wallonia.fr.avg.fisher.z) + 1)
  
  # Append results
  wallonia.fr.correlation.results[[length(wallonia.fr.correlation.results) + 1]] <- list(
    theme = prefix,
    avg_abs_corr = wallonia.fr.avg.abs.corr.matrix,
    adj_avg_abs_corr = wallonia.fr.avg.adj.corr,
    fisher_z_corr = wallonia.fr.avg.fisher.corr
  )
}

# Convert list to dataframe
wallonia.fr.correlations.df <- do.call(rbind, lapply(wallonia.fr.correlation.results, as.data.frame))

# Save to Excel
write_xlsx(wallonia.fr.correlations.df, "files/wallonia_fr_correlations_df.xlsx")

################################################################################
## LOAD DATA: PARTY POSITIONS
################################################################################

# Load the party positions data from an Excel sheet
wallonia.fr.positions <- read_excel("positions.xlsx", sheet = "wallonia_fr")

# Reshape the data from wide to long format (for easier analysis)
wallonia.fr.positions.long <- wallonia.fr.positions %>%
  pivot_longer(
    cols = starts_with("party"),  # Specify the columns to pivot
    names_to = "party",           # New column for the former column names
    values_to = "value"           # New column for the values
  )

# Reshape data from long format to wide format using pivot_wider
wallonia.fr.positions.wide <- wallonia.fr.positions.long %>% 
  dplyr::select(-statement) %>%  # Remove the 'statement' column
  pivot_wider(
    names_from = SID,            # Use 'SID' to create new column names
    values_from = value          # Use 'value' to fill the new columns
  )

################################################################################
## KEEP COMMON COLUMNS
################################################################################

# Remove columns with constant values
stemtest.wallonia.fr.df <- stemtest.wallonia.fr.df[, sapply(stemtest.wallonia.fr.df, function(x) length(unique(x)) > 1)]
wallonia.fr.positions.wide <- wallonia.fr.positions.wide[, sapply(wallonia.fr.positions.wide, function(x) length(unique(x)) > 1)]

# Remove columns that contain one or more '99' values
wallonia.fr.positions.wide <- wallonia.fr.positions.wide[, !apply(wallonia.fr.positions.wide, 2, function(x) any(x == 99))]

# Find the common column names between the dataframes 'stemtest.wallonia.fr.df' and 'wallonia.fr.positions.wide'
wallonia.fr.common.columns <- intersect(names(stemtest.wallonia.fr.df), names(wallonia.fr.positions.wide))

# Subset the wide dataframe to keep only the common columns
wallonia.fr.positions.wide <- wallonia.fr.positions.wide[, wallonia.fr.common.columns]
stemtest.wallonia.fr.df.combine <- stemtest.wallonia.fr.df[, wallonia.fr.common.columns]

################################################################################
## CREATE MAIN DATAFRAME FOR PARTY POSITIONS
################################################################################

# Recode values in the position columns: Replace '2' with '0'
wallonia.fr.positions.wide <- wallonia.fr.positions.wide %>%
  mutate(across(everything(), ~ replace(., . == 2, 0)))

# Convert all opinion columns (of type double) to numeric format
wallonia.fr.positions.wide <- wallonia.fr.positions.wide %>%
  mutate(across(where(is.double), as.numeric))

################################################################################
## CREATE CORRELATION MATRIX: CITIZENS
################################################################################

# Count the total number of sessions in the data
n.stemtest.wallonia.fr.df <- nrow(stemtest.wallonia.fr.df.combine)

# Compute Kuder-Richardson Formula 20 (reliability coefficient)
#kr20_value <- validateR::kr20(stemtest.wallonia.fr.df.combine)

# Compute tetrachoric correlation for the opinion data
wallonia.fr.tetrachoric.corr <- tetrachoric(stemtest.wallonia.fr.df.combine)

# Extract the correlation matrix and convert it to absolute values
wallonia.fr.cor.matrix  <- abs(wallonia.fr.tetrachoric.corr$rho)

# Calculate the average absolute correlation for each row
wallonia.fr.avg.abs.corr.matrix <- rowMeans(wallonia.fr.cor.matrix)

# Convert the correlation matrix to long format (for easier visualization)
wallonia.fr.cor.matrix.long <- reshape2::melt(wallonia.fr.cor.matrix)
wallonia.fr.cor.matrix.long$Matrix <- "(a) Citizens"  # Label for the first matrix

# Perform hierarchical clustering on the correlation matrix
wallonia.fr.hc <- hclust(as.dist(1 - wallonia.fr.cor.matrix), method = "complete")

# Get the order of items after hierarchical clustering
wallonia.fr.ordered.names <- rownames(wallonia.fr.cor.matrix)[wallonia.fr.hc$order]

# Reorder the correlation matrix according to the clustering order
wallonia.fr.cor.matrix.reordered  <- wallonia.fr.cor.matrix[wallonia.fr.hc$order, wallonia.fr.hc$order]

# Load labels to rename the columns and rows of the correlation matrix
labels.df <- read_excel("labels.xlsx", col_names = TRUE)

# Clean up the labels data (add new codes and labels)
labels.df <- labels.df %>%
  #mutate(new_column = paste0("T", as.integer(factor(category)))) %>%
  mutate(new_column = paste0(abbr)) %>%
  mutate(
    new_code = paste0(new_column, ". ", code),
    new_label = paste0(new_column, ". ", label)
  ) %>%
  arrange(category)

# Merge the labels with the correlation matrix data
wallonia.fr.cor.matrix.long <- merge(wallonia.fr.cor.matrix.long, labels.df, by.x = "Var1", by.y = "code")
wallonia.fr.cor.matrix.long <- merge(wallonia.fr.cor.matrix.long, labels.df, by.x = "Var2", by.y = "code")

# Label the rows and columns of the reordered correlation matrix
labels <- labels.df$label[match(colnames(wallonia.fr.cor.matrix.reordered), labels.df$code)]
rownames(wallonia.fr.cor.matrix.reordered) <- labels

# Perform hypothesis testing to compute p-values for the correlations
wallonia.fr.ptest <- cor.mtest(wallonia.fr.cor.matrix.reordered , conf.level = 0.95)

# Calculate the proportion of statistically significant correlations (p-value < 0.05)
wallonia.fr.mean.sig <- mean(wallonia.fr.ptest$p[upper.tri(wallonia.fr.ptest$p)] < 0.05)

# Set diagonal values of the correlation matrix to NA (self-correlations should be ignored)
wallonia.fr.cor.matrix.reordered.diag <- wallonia.fr.cor.matrix.reordered 
diag(wallonia.fr.cor.matrix.reordered.diag) <- NA

# Compute the average of the non-diagonal absolute correlations
wallonia.fr.mean.abs.corr <- mean(wallonia.fr.cor.matrix.reordered.diag, na.rm = TRUE)

# Flatten the matrix into a vector for easier analysis
wallonia.fr.cor.vector <- as.vector(wallonia.fr.cor.matrix.reordered.diag)

# Count the number of correlations with absolute value greater than or equal to 0.4 and 0.2
wallonia.fr.num.above.0.4 <- sum(abs(wallonia.fr.cor.vector) >= 0.4, na.rm = TRUE)
wallonia.fr.num.above.0.2 <- sum(abs(wallonia.fr.cor.vector) >= 0.2, na.rm = TRUE)

# Calculate the total number of correlations
wallonia.fr.num.total <- length(wallonia.fr.cor.vector)

# Calculate the percentage of correlations above the thresholds
wallonia.fr.percentage.above.0.4 <- (wallonia.fr.num.above.0.4 / wallonia.fr.num.total) * 100
wallonia.fr.percentage.above.0.2 <- (wallonia.fr.num.above.0.2 / wallonia.fr.num.total) * 100

################################################################################
## CREATE CORRELATION MATRIX: PARTIES
################################################################################

# Apply the Kuder-Richardson Formula 20 to validate the data
#pkr20_value <- validateR::kr20(wallonia.fr.positions.wide)

# Compute the tetrachoric correlation matrix
wallonia.fr.tetrachoric.corr.p <- tetrachoric(wallonia.fr.positions.wide)
wallonia.fr.cor.matrix.p  <- wallonia.fr.tetrachoric.corr.p$rho

# Take the absolute values of the correlation matrix
wallonia.fr.cor.matrix.p  <- abs(wallonia.fr.cor.matrix.p)

# Convert the correlation matrix to long format for easier manipulation
wallonia.fr.cor.matrix.p.long <- reshape2::melt(abs(wallonia.fr.cor.matrix.p))
wallonia.fr.cor.matrix.p.long$Matrix <- "(b) Party leaders"  # Label the matrix for visualization

# Merge with 'labels.df' to get descriptive labels for the columns/rows
wallonia.fr.cor.matrix.p.long <- merge(wallonia.fr.cor.matrix.p.long, labels.df, by.x = "Var1", by.y = "code")
wallonia.fr.cor.matrix.p.long <- merge(wallonia.fr.cor.matrix.p.long, labels.df, by.x = "Var2", by.y = "code")

# Perform hierarchical clustering on the correlation matrix
wallonia.fr.hc.p <- hclust(as.dist(1 - wallonia.fr.cor.matrix.p), method = "complete")

# Reorder the correlation matrix based on the hierarchical clustering order
wallonia.fr.cor.matrix.p.reordered  <- wallonia.fr.cor.matrix.p[wallonia.fr.ordered.names, wallonia.fr.ordered.names]

# Assign labels to the reordered matrix columns and rows based on 'labels.df'
labels <- labels.df$label[match(colnames(wallonia.fr.cor.matrix.p.reordered), labels.df$code)]
rownames(wallonia.fr.cor.matrix.p.reordered) <- labels

# Compute the confidence intervals for each pair of items in the correlation matrix
pitemsCols <- 1:ncol(wallonia.fr.cor.matrix.p.reordered)
wallonia.fr.ptest.p <- cor.mtest(wallonia.fr.cor.matrix.p.reordered[ , pitemsCols], conf.level = 0.95)

# Calculate the proportion of statistically significant correlations
wallonia.fr.mean.sig.p <- mean(wallonia.fr.ptest.p$p[upper.tri(wallonia.fr.ptest.p$p)] < 0.05)

# Set diagonal values of the matrix to NA (ignores self-correlations)
wallonia.fr.cor.matrix.p.reordered.diag <- wallonia.fr.cor.matrix.p.reordered 
diag(wallonia.fr.cor.matrix.p.reordered.diag) <- NA

# Compute the average of the non-diagonal absolute correlations
wallonia.fr.mean.abs.corr.p <- mean(wallonia.fr.cor.matrix.p.reordered.diag, na.rm = TRUE)

# Flatten the matrix into a vector for further analysis
wallonia.fr.cor.vector.p <- as.vector(wallonia.fr.cor.matrix.p.reordered.diag)

# Count the number of correlations with an absolute value ≥ 0.4
wallonia.fr.num.above.0.4.p <- sum(abs(wallonia.fr.cor.vector.p) >= 0.4, na.rm = TRUE)

# Count the number of correlations with an absolute value ≥ 0.2
wallonia.fr.num.above.0.2.p <- sum(abs(wallonia.fr.cor.vector.p) >= 0.2, na.rm = TRUE)

# Calculate the total number of correlations
wallonia.fr.num.total.p <- length(wallonia.fr.cor.vector.p)

# Calculate the percentage of correlations that are ≥ 0.4 and ≥ 0.2
wallonia.fr.percentage.above.0.4.p <- (wallonia.fr.num.above.0.4.p / wallonia.fr.num.total.p) * 100
wallonia.fr.percentage.above.0.2.p <- (wallonia.fr.num.above.0.2.p / wallonia.fr.num.total.p) * 100

################################################################################
## CORRELATION BETWEEN THE TWO MATRICES
################################################################################

# Extract correlation matrices from tetrachoric objects
wallonia.fr.tetrachoric.matrix <- wallonia.fr.tetrachoric.corr$rho
wallonia.fr.tetrachoric.matrix.p <- wallonia.fr.tetrachoric.corr.p$rho

# Helper to flatten lower triangle
flatten_corr <- function(corr_matrix) {
  corr_matrix[lower.tri(corr_matrix)]
}

# 1. SCATTERPLOT OF CORRELATIONS WITH CORRELATION VALUE
wallonia.fr.vec.citizens <- flatten_corr(wallonia.fr.tetrachoric.matrix)
wallonia.fr.vec.parties <- flatten_corr(wallonia.fr.tetrachoric.matrix.p)
wallonia.fr.vec <- data.frame(Citizen = wallonia.fr.vec.citizens, Politician = wallonia.fr.vec.parties)

# Compute Pearson correlation
wallonia.fr.corr.val <- cor(wallonia.fr.vec$Citizen, wallonia.fr.vec$Politician, use = "complete.obs")

# Format correlation value to show two decimal places
wallonia.fr.corr.val <- sprintf("%.2f", wallonia.fr.corr.val)

png("figs/wallonia_fr_scatter_plot.png", units = "in", width = 10, height = 8, res = 300)

# Create the plot with improved styling
wallonia.fr.scatter.plot <- ggplot(wallonia.fr.vec, aes(x = Citizen, y = Politician)) +
  geom_point(alpha = 0.6) +
  geom_smooth(method = "lm", color = "red", se = FALSE) +
  scale_x_continuous(limits = c(-1, 1), breaks = seq(-1, 1, by = 0.2)) +  # Custom x-axis
  annotate("text", x = min(wallonia.fr.vec$Citizen, na.rm = TRUE) - 0.28,  # Move to left
           y = max(wallonia.fr.vec$Politician, na.rm = TRUE) + 0.05,  # Move to top
           label = paste0("r = ", wallonia.fr.corr.val),
           hjust = 0, vjust = 1, size = 4.5) +
  labs(x = "Citizens' Tetrachoric Correlations",
       y = "Party Leaders' Tetrachoric Correlations") +
  theme_minimal(base_size = 16) +
  theme(
    plot.title = element_blank(),  # remove title
    axis.title.x = element_text(margin = margin(t = 15), size = 16),
    axis.title.y = element_text(margin = margin(r = 15), size = 16),
    axis.text = element_text(size = 13)
  )

wallonia.fr.scatter.plot

dev.off()

# 2. DIFFERENCE HEATMAP (clipped to [-1, 1])
par(mfrow = c(1, 1))  # Reset layout
wallonia.fr.diff.corr <- wallonia.fr.tetrachoric.matrix - wallonia.fr.tetrachoric.matrix.p
wallonia.fr.diff.corr.clipped <- pmax(pmin(wallonia.fr.diff.corr, 1), -1)  # clip values to [-1, 1]

corrplot(wallonia.fr.diff.corr.clipped, method = "color", tl.cex = 0.7, mar = c(0, 0, 2, 0))
#title("Citizen - Politician Correlations", line = 1)

################################################################################
## CREATE FACETED PLOT
################################################################################

# Combine the correlation matrices (from citizens and parties) into a single long-format dataframe
wallonia.fr.long.combined <- rbind(wallonia.fr.cor.matrix.long, wallonia.fr.cor.matrix.p.long)

# Select and organize necessary columns for further analysis and visualization
wallonia.fr.long.combined <- wallonia.fr.long.combined %>%
  select(new_code.x, new_code.y, new_label.x, new_label.y, value, category.x, category.y, Matrix)

# Convert codes to factors for better handling of categorical data
wallonia.fr.long.combined$new_code.x <- as.factor(wallonia.fr.long.combined$new_code.x)
wallonia.fr.long.combined$new_code.y <- as.factor(wallonia.fr.long.combined$new_code.y)

# Calculate the average absolute correlation for each row (excluding diagonal)
wallonia.fr.long.combined <- wallonia.fr.long.combined %>%
  group_by(new_code.x, Matrix) %>%
  mutate(avg_corr = mean(abs(value[new_code.x != new_code.y]), na.rm = TRUE)) %>%
  ungroup()

# Prepare data for labeling the average correlation values at the end of each row
wallonia.fr.avg.corr.labels <- wallonia.fr.long.combined %>%
  distinct(new_code.x, avg_corr, Matrix) %>%
  mutate(x_position = max(as.numeric(wallonia.fr.long.combined$new_code.y)))

# Merge with 'labels.df' to get descriptive labels for the codes
wallonia.fr.avg.corr.labels <- wallonia.fr.avg.corr.labels %>%
  mutate(new_code.x = as.character(new_code.x)) %>% 
  left_join(labels.df, by = c("new_code.x" = "new_code")) %>%
  rename(new_label.x = new_label)

# Calculate the maximum x-position from the data for plot adjustments
wallonia.fr.max.x.position <- max(as.numeric(wallonia.fr.long.combined$new_code.y))

# Set an offset for the average correlation labels (to avoid overlap)
wallonia.fr.offset.x <- 1.25  # A smaller offset to avoid pushing labels too far out

# Prepare the labels for average correlation, adjusting the position to the right of the plot
wallonia.fr.avg.corr.labels <- wallonia.fr.avg.corr.labels %>%
  mutate(x_position = wallonia.fr.max.x.position + wallonia.fr.offset.x)

# Merge the average correlation data with labels to ensure proper matching
wallonia.fr.avg.corr.labels <- left_join(wallonia.fr.avg.corr.labels, labels.df, by = "code")
wallonia.fr.avg.corr.labels <- wallonia.fr.avg.corr.labels %>%
  rename(new_label.y = new_label)

# Reorder the labels according to the ordered names
wallonia.fr.ordered.names.df <- data.frame(code = wallonia.fr.ordered.names)
wallonia.fr.merged.data <- merge(wallonia.fr.ordered.names.df, labels.df, by = "code")
wallonia.fr.labeled.vector <- wallonia.fr.merged.data$new_label
wallonia.fr.ordered.names <- wallonia.fr.merged.data$new_code

# Update the factor levels of the columns based on ordered names
wallonia.fr.long.combined$new_code.x <- factor(wallonia.fr.long.combined$new_code.x, levels = wallonia.fr.ordered.names)
wallonia.fr.long.combined$new_label.y <- factor(wallonia.fr.long.combined$new_label.y, levels = wallonia.fr.labeled.vector)

# Filter and prepare data for the citizens matrix (Matrix == "(a) Citizens")
wallonia.fr.avg.corr.labels_citizens <- wallonia.fr.avg.corr.labels[wallonia.fr.avg.corr.labels$Matrix == "(a) Citizens", ]

# Order the rows in the citizens matrix by average correlation values
wallonia.fr.avg.corr.labels_citizens$new_code.x <- factor(wallonia.fr.avg.corr.labels_citizens$new_code.x, 
                                                    levels = wallonia.fr.avg.corr.labels_citizens$new_code.x[order(wallonia.fr.avg.corr.labels_citizens$avg_corr)])
wallonia.fr.new.order <- levels(wallonia.fr.avg.corr.labels_citizens$new_code.x)

# Reorder the factors based on the new order for the plot
wallonia.fr.ordered.names.df <- data.frame(new_code = wallonia.fr.new.order)
wallonia.fr.merged.data <- left_join(wallonia.fr.ordered.names.df, labels.df, by = "new_code")
wallonia.fr.labeled.vector <- wallonia.fr.merged.data$new_label
wallonia.fr.ordered.names <- wallonia.fr.ordered.names.df$new_code

# Update the levels of the factor for plotting
wallonia.fr.long.combined$new_code.x <- factor(wallonia.fr.long.combined$new_code.x, levels = wallonia.fr.ordered.names)
wallonia.fr.long.combined$new_label.y <- factor(wallonia.fr.long.combined$new_label.y, levels = wallonia.fr.labeled.vector)

# Final plot creation using ggplot2
png("figs/wallonia_fr_combined_g.png", units="in", width=17, height=9, res=1200)

# Create the ggplot
ggplot(wallonia.fr.long.combined, aes(new_code.x, new_label.y, fill = value)) +  # Define the basic aesthetics (x and y variables, fill color)
  
  # Add geom_tile() for creating heatmap-like tiles
  geom_tile() +
  
  # Set the color scale with gradient from white to black, and adjust limits and breaks for the scale
  scale_fill_gradient(
    low = "white",  # Color for low values
    high = "black",  # Color for high values
    limits = c(0, max(abs(wallonia.fr.long.combined$value))),  # Set the limits of the color scale to cover all values
    breaks = seq(0, max(abs(wallonia.fr.long.combined$value)), by = 0.2)  # Specify breaks for color scale
  ) + 
  
  # Use a minimal theme for a clean background
  theme_minimal() +
  
  # Facet the plot into multiple panels based on the "Matrix" variable
  facet_wrap(~ Matrix) + 
  
  # Rotate the x-axis labels for better visibility (90-degree rotation)
  theme(axis.text.x = element_text(angle = 90, hjust = 1)) +
  
  # Add the plot title and caption with dynamic text
  labs(title = "Comparison of Two Correlation Matrices",
       x = "Variables", y = "Variables",
       caption = paste("Number of online sessions:", comma(n.stemtest.wallonia.fr.df),
                       "\nMean absolute correlation coefficient: (a)", sprintf("%.2f", wallonia.fr.mean.abs.corr), 
                       "(b)", sprintf("%.2f", wallonia.fr.mean.abs.corr.p),
                       "\nPercentage of correlations ≥ 0.2: (a)", sprintf("%.2f%%", wallonia.fr.percentage.above.0.2), 
                       "(b)", sprintf("%.2f%%", wallonia.fr.percentage.above.0.2.p),
                       "\nPercentage of correlations ≥ 0.4: (a)", sprintf("%.2f%%", wallonia.fr.percentage.above.0.4), 
                       "(b)", sprintf("%.2f%%", wallonia.fr.percentage.above.0.4.p), 
                       "\nCorrelation of correlations:", wallonia.fr.corr.val)) +
  
  # Customize text sizes, remove titles, and format the plot to improve readability
  theme(
    axis.text.x = element_text(size = 10.5, angle = 90, vjust = 0.5),  # Rotate x-axis labels and adjust size
    axis.text.y = element_text(size = 10.5),  # Adjust size of y-axis labels
    axis.title.x = element_blank(),  # Remove x-axis title
    axis.title.y = element_blank(),  # Remove y-axis title
    legend.title = element_blank(),  # Remove legend title
    plot.title = element_blank(),    # Remove plot title
    panel.grid.major = element_blank(),  # Remove major grid lines
    panel.grid.minor = element_blank(),  # Remove minor grid lines
    plot.caption = element_text(size = 12),  # Adjust caption size
    strip.text = element_text(size = 16),  # Adjust size of facet labels
    panel.spacing.x = unit(.3, "cm"),  # Set space between panels
    legend.position = "bottom",  # Position the legend at the bottom
    legend.direction = "horizontal",  # Make the legend horizontal
    legend.key.height = unit(0.4, "cm"),  # Adjust the height of the legend keys
    legend.key.width = unit(2, "cm"),  # Adjust the width of the legend keys
    legend.text = element_text(size = 11),  # Adjust legend text size
    plot.margin = margin(0, 0, 0, 0, "cm")  # Set plot margins to zero for a tighter fit
  ) +
  
  # Customize x-axis labels using ggtext for HTML formatting to add color
  scale_x_discrete(labels = function(x) {
    x <- gsub("^ECONOMY(?=\\.)", "<span style='color:#800000;'><b>ECONOMY</b></span>", x, perl = TRUE)  # Add color for ECFL
    x <- gsub("^EDUCATION(?=\\.)", "<span style='color:#9A6324;'><b>EDUCATION</b></span>", x, perl = TRUE)  # Add color for EDUC
    x <- gsub("^ENVIRONMENT(?=\\.)", "<span style='color:#3cb44b;'><b>ENVIRONMENT</b></span>", x, perl = TRUE)  # Add color for ENEG
    x <- gsub("^ETHICS(?=\\.)", "<span style='color:#f58231;'><b>ETHICS</b></span>", x, perl = TRUE)  # Add color for ETHE
    x <- gsub("^FOREIGN(?=\\.)", "<span style='color:#ffe119;'><b>FOREIGN</b></span>", x, perl = TRUE)  # Add color for FAED
    x <- gsub("^WELFARE(?=\\.)", "<span style='color:#bfef45;'><b>WELFARE</b></span>", x, perl = TRUE)  # Add color for HSWF
    x <- gsub("^IMMIGRATION(?=\\.)", "<span style='color:#e6194B;'><b>IMMIGRATION</b></span>", x, perl = TRUE)  # Add color for IMIN
    x <- gsub("^CRIME(?=\\.)", "<span style='color:#42d4f4;'><b>CRIME</b></span>", x, perl = TRUE)  # Add color for JLEF
    x <- gsub("^CULTURE(?=\\.)", "<span style='color:#f032e6;'><b>CULTURE</b></span>", x, perl = TRUE)  # Add color for MECU
    x <- gsub("^MOBILITY(?=\\.)", "<span style='color:#4363d8;'><b>MOBILITY</b></span>", x, perl = TRUE)  # Add color for MPTR
    x <- gsub("^HOUSING(?=\\.)", "<span style='color:#000075;'><b>HOUSING</b></span>", x, perl = TRUE)  # Add color for SPHO
    x <- gsub("^STATE(?=\\.)", "<span style='color:#911eb4;'><b>STATE</b></span>", x, perl = TRUE)  # Add color for SRPI
    return(x)
  }) +
  
  # Similarly, customize the y-axis labels with color formatting
  scale_y_discrete(labels = function(y) {
    y <- gsub("ECONOMY(?=\\.)", "<span style='color:#800000;'><b>ECONOMY</b></span>", y, perl = TRUE)  # Add color for ECFL
    y <- gsub("EDUCATION(?=\\.)", "<span style='color:#9A6324;'><b>EDUCATION</b></span>", y, perl = TRUE)  # Add color for EDUC
    y <- gsub("ENVIRONMENT(?=\\.)", "<span style='color:#3cb44b;'><b>ENVIRONMENT</b></span>", y, perl = TRUE)  # Add color for ENEG
    y <- gsub("ETHICS(?=\\.)", "<span style='color:#f58231;'><b>ETHICS</b></span>", y, perl = TRUE)  # Add color for ETHE
    y <- gsub("FOREIGN(?=\\.)", "<span style='color:#ffe119;'><b>FOREIGN</b></span>", y, perl = TRUE)  # Add color for FAED
    y <- gsub("WELFARE(?=\\.)", "<span style='color:#bfef45;'><b>WELFARE</b></span>", y, perl = TRUE)  # Add color for HSWF
    y <- gsub("IMMIGRATION(?=\\.)", "<span style='color:#e6194B;'><b>IMMIGRATION</b></span>", y, perl = TRUE)  # Add color for IMIN
    y <- gsub("CRIME(?=\\.)", "<span style='color:#42d4f4;'><b>CRIME</b></span>", y, perl = TRUE)  # Add color for JLEF
    y <- gsub("CULTURE(?=\\.)", "<span style='color:#f032e6;'><b>CULTURE</b></span>", y, perl = TRUE)  # Add color for MECU
    y <- gsub("MOBILITY(?=\\.)", "<span style='color:#4363d8;'><b>MOBILITY</b></span>", y, perl = TRUE)  # Add color for MPTR
    y <- gsub("HOUSING(?=\\.)", "<span style='color:#000075;'><b>HOUSING</b></span>", y, perl = TRUE)  # Add color for SPHO
    y <- gsub("STATE(?=\\.)", "<span style='color:#911eb4;'><b>STATE</b></span>", y, perl = TRUE)  # Add color for SRPI
    return(y)
  }) +
  
  # Enable Markdown formatting for axis labels (to support HTML formatting)
  theme(axis.text.x = element_markdown(),
        axis.text.y = element_markdown()) +  
  
  # Add average absolute correlation labels at the end of each row, only for certain matrices
  geom_text(data = wallonia.fr.avg.corr.labels %>%
              filter(Matrix == "(a) Citizens" | Matrix == "(b) Party leaders"),  # Filter data for the labels
            aes(x = x_position, y = new_label.y, label = sprintf("%.2f", avg_corr)),
            inherit.aes = FALSE, size = 4, hjust = 0, vjust = 0.5) +  # Adjust label positioning
  
  # Expand x-axis to accommodate labels just outside the plot area
  coord_cartesian(xlim = c(NA, wallonia.fr.max.x.position + wallonia.fr.offset.x + 2))  # Set x-axis limit

# Save the plot to a file
dev.off()

################################################################################
## MEAN ABSOLUTE CORRELATION BY PARTY SUGGESTION
################################################################################

# Custom color palette for political party labels
party_palette <- c("NVA" = "#FCBD1B", "VB" = "black", "CDV" = "#FF6000", 
                   "PVDA" = "#EF4135", "VLD" = "#005DAA",
                   "VOORUIT" = "#FF2900", "GROEN" = "#02AD5B", "PS" = "#FF0000", 
                   "MR" = "#002EFF", "Ecolo" = "#088C39", "LesEngages" = "#00E6D2", 
                   "Defi" = "#DD007A")

# Define party logo image labels using HTML <img> tags
party.img.labels <- c(
  "CDV" = "<img src='logos/CDV.png' width='40' />",      # Christian Democratic Party (CDV) logo
  "Defi" = "<img src='logos/Defi.png' width='40' />",     # Defi party logo
  "Ecolo" = "<img src='logos/Ecolo.png' width='40' />",   # Ecolo party logo
  "GROEN" = "<img src='logos/GROEN.png' width='40' />",   # Groen party logo
  "LesEngages" = "<img src='logos/LesEngages.png' width='43' />", # Les Engagés party logo
  "MR" = "<img src='logos/MR.png' width='38' />",         # Mouvement Réformateur (MR) logo
  "NVA" = "<img src='logos/NVA.png' width='48' />",       # New Flemish Alliance (NVA) logo
  "VLD" = "<img src='logos/VLD.png' width='48' />",       # Open Flemish Liberals and Democrats (VLD) logo
  "PS" = "<img src='logos/PS.png' width='30' />",         # Socialist Party (PS) logo
  "PVDA" = "<img src='logos/PVDA.png' width='48' />",     # Workers' Party of Belgium (PVDA) logo
  "PTB" = "<img src='logos/PTB.png' width='48' />",           # Workers' Party of Belgium (PTB) logo
  "VB" = "<img src='logos/VB.png' width='48' />",         # Vlaams Belang (VB) logo
  "VOORUIT" = "<img src='logos/VOORUIT.png' width='53' />") # Vooruit party logo

# Add a new column 'image' to the data frame, containing the party logo image paths based on the party 'advice' column
stemtest.wallonia.fr.avg.byparty$image <- paste0("logos/", stemtest.wallonia.fr.avg.byparty$advice, ".png")

# Save the plot as a high-resolution PNG image
png("figs/stemtest_wallonia_fr_byparty.png", units="in", width=6, height=5, res=1200)

# Create a horizontal bar plot using ggplot2
ggplot(stemtest.wallonia.fr.avg.byparty, aes(x = avg_abs_tetra, y = reorder(advice, avg_abs_tetra), fill = advice)) +
  geom_col() +  # Create bars for each party with the average correlation value
  geom_vline(xintercept = wallonia.fr.mean.abs.corr, linetype = "dashed", color = "black", linewidth = 0.4) +  # Add a dashed vertical line for the mean correlation
  # Replace y-axis labels with party logos (using the 'party.img.labels' vector defined earlier)
  scale_y_discrete(labels = party.img.labels) + 
  # Apply custom color palette to fill bars based on party
  scale_fill_manual(values = party_palette) + 
  # Remove the legend as it's unnecessary for this plot
  guides(fill = "none") + 
  # Add numeric labels to each bar, formatted to two decimal places
  geom_text(aes(label = sprintf("%.2f", avg_abs_tetra)),  # Format labels to 2 decimal places
            position = position_stack(vjust = .92),  # Position labels within the bars
            size = 3, color = "white") +  # Set label text size and color
  theme_minimal() +  # Use a minimal theme for a clean look
  theme(
    axis.text.y = element_markdown(lineheight = 1.2),  # Render HTML content (party logos) on the y-axis
    axis.text.x = element_text(size = 10),  # Set smaller font size for x-axis labels
    axis.ticks.y = element_blank(),  # Remove the y-axis ticks
    axis.title.x = element_text(size = 10, margin = margin(t = 10)),  # Reduce font size of x-axis title
    plot.margin = margin(0, 1, 0, 3)  # Increase space on the left for party logos to fit
  ) +
  labs(
    x = "Mean absolute correlation",  # Set x-axis title
    y = NULL,  # No y-axis title
    title = NULL  # Remove default plot title
  )

# Close the PNG device to save the plot
dev.off()

################################################################################
## CONFIRMATORY FACTOR ANALYSIS
################################################################################

# Ensure that `labels_df$code` contains only the columns that exist in `stemtest.wallonia.fr.df`
# This step filters out any codes in `labels_df` that do not have corresponding columns in the data frame
labels_df <- labels.df %>% filter(code %in% colnames(stemtest.wallonia.fr.df.wgt))

# Create a named vector `rename_map` that maps each old column name to a new name
# The new names combine the old code and corresponding topic (e.g., "code_topic")
rename_map <- setNames(paste0(labels_df$code, "_", labels_df$topic), labels_df$code)

# Rename the columns of `stemtest.wallonia.fr.df` according to `rename_map`
# This ensures that column names are more informative by combining the code and the topic
stemtest.wallonia.fr.df.cfa <- stemtest.wallonia.fr.df.wgt %>%
  rename_with(~ rename_map[.x], .cols = all_of(labels_df$code))

# Remove NA values
stemtest.wallonia.fr.df.cfa <- na.omit(stemtest.wallonia.fr.df.cfa)

## SPECIFY MODELS
################################################################################

# (A) One-factor model: All items load onto a single "ideology" factor

# Extract the column names from the data frame (excluding "_Other" items)
stemtest.wallonia.fr.items <- colnames(stemtest.wallonia.fr.df.cfa)
stemtest.wallonia.fr.items <- stemtest.wallonia.fr.items[!grepl("_Other", stemtest.wallonia.fr.items) & 
                                               stemtest.wallonia.fr.items != "person_weights"]

# Define the CFA model for the one-factor model: all variables are indicators of a single latent factor "ideology"
stemtest.wallonia.fr.cfa.model.1f <- paste0("ideology =~ ", paste(stemtest.wallonia.fr.items, collapse = " + "))

# (B) Two-factor model: Items are split into two factors: Economic vs Socio-cultural

# Identify variables related to economic and socio-cultural factors based on their suffix
stemtest.wallonia.fr.economic.vars <- grep("_Economic$", names(stemtest.wallonia.fr.df.cfa), value = TRUE)
stemtest.wallonia.fr.cultural.vars <- grep("_Cultural$", names(stemtest.wallonia.fr.df.cfa), value = TRUE)

# Remove the suffix "_Economic" from the economic variable names for better readability
stemtest.wallonia.fr.economic.vars <- gsub("_Economic$", "", unlist(stemtest.wallonia.fr.economic.vars))

# Remove the suffix "_Cultural" from the cultural variable names for better readability
stemtest.wallonia.fr.cultural.vars <- gsub("_Cultural$", "", unlist(stemtest.wallonia.fr.cultural.vars))

# Define the CFA model for the two-factor model: 
# Economic items load on the "Economic" factor and Cultural items load on the "Cultural" factor
stemtest.wallonia.fr.cfa.model.2f <- paste(
  "Economic =~", paste(stemtest.wallonia.fr.economic.vars, collapse = " + "), "\n",
  "Cultural =~", paste(stemtest.wallonia.fr.cultural.vars, collapse = " + ")
)

## RUN CFA
################################################################################

# Fit the one-factor model using the WLSMV estimator (appropriate for binary data)
stemtest.wallonia.fr.cfa.fit.1f <- cfa(stemtest.wallonia.fr.cfa.model.1f, 
                                 data = stemtest.wallonia.fr.df.cfa, 
                                 sampling.weights = "person_weights",
                                 ordered = colnames(stemtest.wallonia.fr.df.cfa), 
                                 estimator = "WLSMV")

# Clean up the column names of the data by removing everything after the first "_"
cols_to_rename <- setdiff(colnames(stemtest.wallonia.fr.df.cfa), "person_weights")
new_names <- sapply(strsplit(cols_to_rename, "_"), `[`, 1)
colnames(stemtest.wallonia.fr.df.cfa)[colnames(stemtest.wallonia.fr.df.cfa) != "person_weights"] <- new_names

# Fit the two-factor model (no estimator specified here as it's already default for binary data)
stemtest.wallonia.fr.cfa.fit.2f <- cfa(stemtest.wallonia.fr.cfa.model.2f, 
                                 data = stemtest.wallonia.fr.df.cfa, 
                                 sampling.weights = "person_weights",
                                 ordered = colnames(stemtest.wallonia.fr.df.cfa))

## DIAGNOSTICS AND MODEL COMPARISON
################################################################################

# Inspect standardized factor loadings to check if they are sufficiently strong (typically > 0.5)
parameterEstimates(stemtest.wallonia.fr.cfa.fit.1f, standardized = TRUE) %>%
  filter(op == "=~") # Extract factor loadings for the one-factor model
parameterEstimates(stemtest.wallonia.fr.cfa.fit.2f, standardized = TRUE) %>%
  filter(op == "=~") # Extract factor loadings for the two-factor model

# Check overall model fit indices for both models (values close to 1 indicate good fit)
summary(stemtest.wallonia.fr.cfa.fit.1f, fit.measures = TRUE, standardized = TRUE)
summary(stemtest.wallonia.fr.cfa.fit.2f, fit.measures = TRUE, standardized = TRUE)

# Extract fit statistics
stemtest.wallonia.fr.cfa.fit.stats.f1 <- fitMeasures(stemtest.wallonia.fr.cfa.fit.1f, c("chisq", "df", "cfi", "tli", "rmsea", "srmr"))
stemtest.wallonia.fr.cfa.fit.stats.f2 <- fitMeasures(stemtest.wallonia.fr.cfa.fit.2f, c("chisq", "df", "cfi", "tli", "rmsea", "srmr"))

# Create a data frame with selected fit statistics
wallonia.fr.fit.table <- data.frame(
  Model = c("One-Factor", "Two-Factor"),
  RMSEA = c(stemtest.wallonia.fr.cfa.fit.stats.f1["rmsea"], stemtest.wallonia.fr.cfa.fit.stats.f2["rmsea"]),
  CFI   = c(stemtest.wallonia.fr.cfa.fit.stats.f1["cfi"], stemtest.wallonia.fr.cfa.fit.stats.f2["cfi"]),
  TLI   = c(stemtest.wallonia.fr.cfa.fit.stats.f1["tli"], stemtest.wallonia.fr.cfa.fit.stats.f2["tli"]),
  SRMR  = c(stemtest.wallonia.fr.cfa.fit.stats.f1["srmr"], stemtest.wallonia.fr.cfa.fit.stats.f2["srmr"])
)

# Round values for readability
wallonia.fr.fit.table[, 2:5] <- round(wallonia.fr.fit.table [, 2:5], 3)

# Run chi-square difference test
wallonia.fr.lrt.result <- lavTestLRT(stemtest.wallonia.fr.cfa.fit.1f, stemtest.wallonia.fr.cfa.fit.2f)
wallonia.fr.lrt.table <- as.data.frame(wallonia.fr.lrt.result)

# Generate LaTeX table for fit indices
wallonia.fr.fit.xtable <- xtable(wallonia.fr.fit.table, caption = "Fit Statistics for One-Factor and Two-Factor Models")
print(wallonia.fr.fit.xtable, include.rownames = FALSE, caption.placement = "top", booktabs = TRUE)

# Generate LaTeX table for chi-square difference test
wallonia.fr.lrt.xtable <- xtable(wallonia.fr.lrt.table, caption = "Chi-Square Difference Test Between Models")
print(wallonia.fr.lrt.xtable, include.rownames = FALSE, caption.placement = "top", booktabs = TRUE)

## INTERPRETATION
################################################################################

# Retrieve standardized factor loadings for the two-factor model
inspect(stemtest.wallonia.fr.cfa.fit.2f, what = "std")$lambda

# Check the internal consistency (reliability) of the economic and cultural factors using Cronbach's alpha
psych::alpha(stemtest.wallonia.fr.df.cfa[, stemtest.wallonia.fr.economic.vars])  # Reliability for Economic Factor
psych::alpha(stemtest.wallonia.fr.df.cfa[, stemtest.wallonia.fr.cultural.vars])  # Reliability for Cultural Factor

# Save the SEM plot of the two-factor model to a png file
png("figs/wallonia_fr_cfa_sem.png", units="in", width=25, height=15, res=300)

# Plot the two-factor model with standardized factor loadings displayed on the paths
semPaths(
  stemtest.wallonia.fr.cfa.fit.2f,
  what = "path", 
  whatLabels = "std",        # Display standardized estimates on the paths
  style = "ram",             # Use RAM-style diagram for better clarity
  layout = "spring",         # Force-directed layout for better separation of nodes
  fixedStyle = "red",        # Color fixed paths in red
  freeStyle = "black",       # Color free paths in black
  edge.width = 0.4,          # Set edge width for better visibility
  border.width = 0.2,        # Set border width of nodes
  border.color = "black",    # Set border color of nodes
  asize = 1,                 # Set arrow size for paths
  edge.label.bg = TRUE,      # Add background to edge labels for readability
  edge.label.cex = 0.5,      # Increase edge label size for readability
  edge.label.position = 0.7, # Position edge labels at the center of edges
  sizeMan = 4,               # Set the size of observed variable boxes
  sizeLat = 5,               # Set the size of latent variable ovals for emphasis
  color = list(lat = "lightgrey", man = "transparent"),  # Color scheme for variables
  title = FALSE,             # Remove default title from the plot
  intercepts = FALSE,        # Exclude intercepts from the plot
  thresholds = FALSE         # Exclude thresholds from the plot
)

# Add model fit statistics as text annotations on the plot
x_pos <- 0.90
y_pos <- 0.95

text(x = x_pos, y = y_pos, labels = paste("RMSEA:", round(stemtest.wallonia.fr.cfa.rmsea, 3), 
                                          "\nCFI:", round(stemtest.wallonia.fr.cfa.cfi, 3), 
                                          "\nTLI:", round(stemtest.wallonia.fr.cfa.tli, 3)),
     cex = 1.5, col = "black")

dev.off()

# Extract factor loadings from the two-factor model and clean up the 'rhs' variable for clarity
stemtest.wallonia.fr.cfa.f2.loadings <- parameterEstimates(stemtest.wallonia.fr.cfa.fit.2f, standardized = TRUE) %>%
  filter(op == "=~")

# Modify the 'rhs' column to keep only the part before the "_"
stemtest.wallonia.fr.cfa.f2.loadings$rhs <- sub("_.*", "", stemtest.wallonia.fr.cfa.f2.loadings$rhs)

# Merge the factor loadings with the corresponding labels from `labels_df`
stemtest.wallonia.fr.cfa.f2.loadings <- merge(stemtest.wallonia.fr.cfa.f2.loadings, labels_df, by.x = "rhs", by.y = "code")

# Reorder the 'label' variable within each latent factor based on the absolute value of the factor loading
stemtest.wallonia.fr.cfa.f2.loadings <- stemtest.wallonia.fr.cfa.f2.loadings %>%
  group_by(lhs) %>%
  mutate(label = factor(label, levels = label[order(abs(est))])) %>%
  ungroup()

# Save the factor loadings plot as a PNG file
png("figs/wallonia_fr_cfa_f2_loadings.png", units="in", width=7, height=6, res=1200)

# Create a bar plot of the factor loadings for each variable within each factor
ggplot(stemtest.wallonia.fr.cfa.f2.loadings, aes(x = est, y = label, fill = lhs)) +
  geom_bar(stat = "identity", position = "dodge") +
  scale_fill_manual(values = c("#ff7f0e", "#1f77b4")) +  # Customize bar colors
  #scale_x_continuous(limits = c(-4, 4), breaks = seq(-4, 4, by = 2)) +  # Set x-axis range
  labs(
    x = "Loading strength",  # x-axis label for the plot
    y = NULL,  # Remove y-axis label
    fill = "Latent variable"  # Legend title
  ) +
  theme_minimal() +
  theme(
    axis.title.x = element_text(size = 10, margin = margin(t = 8)),  # Customize x-axis title appearance
    legend.title = element_text(size = 9),
    legend.position = "bottom",  # Place legend at the bottom
    legend.key.width = unit(0.5, "cm"),  # Adjust legend key width
    legend.key.height = unit(0.5, "cm")  # Adjust legend key height
  )

dev.off()

################################################################################
## EXPLORATORY FACTOR ANALYSIS
################################################################################

wallonia.fr.tetrachoric.matrix <- tetrachoric(stemtest.wallonia.fr.df)$rho
#wallonia.fr.tetrachoric.matrix <- hetcor(stemtest.wallonia.fr.df)$cor

# Kaiser-Meyer-Olkin criterion: tests the suitability of the data for factor analysis
KMO(wallonia.fr.tetrachoric.matrix)

# Bartlett's test of sphericity: tests whether the correlation matrix is an identity matrix, indicating if factor analysis is appropriate
BARTLETT(stemtest.wallonia.fr.df)

# Eigenvalue method (“Kaiser’s rule”): calculates eigenvalues to determine the number of factors to retain
wallonia.fr.ev <- eigen(wallonia.fr.tetrachoric.matrix) # get eigenvalues
#wallonia.fr.ev <- eigen(cor(stemtest.wallonia.fr.df, use = 'pairwise.complete.obs')) # get eigenvalues
wallonia.fr.ev$values  # returns the eigenvalues for each factor

# Scree plot: visualizes the eigenvalues to help determine the number of factors to retain
scree(wallonia.fr.tetrachoric.matrix, pc=FALSE)  # Use pc=FALSE for factor analysis, without Principal Components

# Parallel analysis scree plot: compares observed eigenvalues with simulated eigenvalues to decide on the number of factors
set.seed(123)  # Set random seed for reproducibility
wallonia.fr.parallel <- fa.parallel(wallonia.fr.tetrachoric.matrix, fa='fa')  # Parallel analysis
wallonia.fr.parallel  # Output the results of parallel analysis
wallonia.fr.parallel$nfact  # Suggested number of factors

# Create data frame from observed eigenvalue data for plotting
wallonia.fr.obs <- data.frame(wallonia.fr.parallel$fa.values)
wallonia.fr.obs$type <- c('Observed Data')  # Label the data as observed
wallonia.fr.obs$num <- c(row.names(wallonia.fr.obs))  # Add factor number as column
wallonia.fr.obs$num <- as.numeric(wallonia.fr.obs$num)  # Convert factor number to numeric
colnames(wallonia.fr.obs) <- c('eigenvalue', 'type', 'num')  # Set column names

# Calculate quantiles for eigenvalues from simulated data, storing the 95th percentile values
percentile <- apply(wallonia.fr.parallel$values,2,function(x) quantile(x,.95))
wallonia.fr.min <- as.numeric(nrow(wallonia.fr.obs))  # Minimum value for selecting the range
wallonia.fr.min <- (4*wallonia.fr.min) - (wallonia.fr.min-1)  # Adjust minimum index
wallonia.fr.max <- as.numeric(nrow(wallonia.fr.obs))  # Maximum value for selecting the range
wallonia.fr.max <- 4*wallonia.fr.max  # Adjust maximum index
wallonia.fr.percentile1 <- percentile[wallonia.fr.min:wallonia.fr.max]  # Select the 95th percentile eigenvalues

# Create a data frame for the simulated eigenvalue data
wallonia.fr.sim <- data.frame(wallonia.fr.percentile1)
wallonia.fr.sim$type <- c('Simulated Data (95th %ile)')  # Label the data as simulated
wallonia.fr.sim$num <- c(row.names(wallonia.fr.obs))  # Add factor number as column
wallonia.fr.sim$num <- as.numeric(wallonia.fr.sim$num)  # Convert factor number to numeric
colnames(wallonia.fr.sim) <- c('eigenvalue', 'type', 'num')  # Set column names

# Merge the observed and simulated eigenvalue data frames
wallonia.fr.eigendat <- rbind(wallonia.fr.obs,wallonia.fr.sim)

# Define a custom theme for the plot
apatheme = theme_bw() + 
  theme(panel.grid.major = element_blank(),
        panel.grid.minor = element_blank(),
        panel.background = element_blank(),
        panel.border = element_blank(),
        text = element_text(family = 'Arial'),
        legend.title = element_blank(),
        legend.position = c(.7, .8),
        axis.line.x = element_line(color = 'black'),
        axis.line.y = element_line(color = 'black'))

# Save the scree plot as a png file
png("figs/wallonia_fr_scree_g.png", units="in", width=8, height=6, res=1200)

# Create the scree plot using ggplot2
wallonia.fr.scree <- ggplot(wallonia.fr.eigendat, aes(x = num, y = eigenvalue, shape = type)) +
  geom_line() +  # Add lines connecting data points
  geom_point(size = 2.5) +  # Add points for each eigenvalue
  scale_y_continuous(name = 'Eigenvalue', limits = c(-.6, 5), breaks = seq(0, 5, 1)) +  # Y-axis labels and limits
  scale_x_continuous(name = 'Factor Number', breaks = min(wallonia.fr.eigendat$num):max(wallonia.fr.eigendat$num)) +  # X-axis labels and limits
  scale_shape_manual(values = c(16, 1)) +  # Define different shapes for observed and simulated data
  geom_vline(xintercept = wallonia.fr.parallel$nfact, linetype = 'dashed') +  # Add vertical line for suggested number of factors
  theme_bw() +  # Apply custom theme
  theme(axis.title.x = element_text(size = 12, margin = margin(t = 18, r = 0, b = 0, l = 0)),
        axis.title.y = element_text(size = 12, margin = margin(t = 0, r = 18, b = 0, l = 0)),
        axis.text.x = element_text(size = 12, color = "black", margin = margin(t = 8, r = 0, b = 0, l = 0)),
        axis.text.y = element_text(size = 12, color = "black", margin = margin(t = 0, r = 8, b = 0, l = 0)),
        legend.position = c(.82, .92),
        legend.title = element_blank(),
        legend.text = element_text(size = 10),
        legend.background = element_blank(),
        legend.key = element_rect(colour = NA, fill = NA),
        axis.ticks.length = unit(.18, "cm"),
        panel.grid.major = element_blank(),
        panel.grid.minor = element_blank())

# Call the plot to render it
wallonia.fr.scree

# Close the file device to save the plot
dev.off()

# Very Simple Structure (VSS) criterion: assesses the simplicity of the factor structure
wallonia.fr.vss <- VSS(wallonia.fr.tetrachoric.matrix)   

# Perform VSS with oblimin rotation
wallonia.fr.vss.r <- VSS(wallonia.fr.tetrachoric.matrix, rotate = "oblimin")
wallonia.fr.vss.r

# Create a scree plot for VSS
VSS.scree(wallonia.fr.tetrachoric.matrix, main = "scree plot")
#VSS.scree(cor(stemtest.wallonia.fr.df, use = 'pairwise.complete.obs'), main = "scree plot")

# Save the VSS plot as a png file
png("figs/wallonia_fr_vss_g.png", units = "in", width = 8, height = 6, res = 300)

# Run and display the results of VSS
wallonia.fr.vss <- VSS(wallonia.fr.tetrachoric.matrix)   
wallonia.fr.vss

# Close the file device for VSS plot
dev.off()

# Velicer's minimum average partial (MAP) test: helps determine the number of factors to retain by minimizing residual variance
MAP(stemtest.wallonia.fr.df, corkind = 'polychoric', verbose = TRUE)

# Testing different factor models with up to 4 factors
#wallonia.fr.nf <- nfactors(stemtest.wallonia.fr.df, n = 4, fm = "ml", cor = "tet")
#wallonia.fr.nf 

# Extract and rotate factors (3 factors in this case)
wallonia.fr.Nfacs <- 3

# Perform factor analysis using oblimin/varimax rotation
#cor_fa <- cor(stemtest.wallonia.fr.df, use = 'pairwise.complete.obs')
wallonia.fr.fit.obl <- factanal(covmat = wallonia.fr.tetrachoric.matrix, factors = wallonia.fr.Nfacs, rotation = "oblimin") # oblimin rotation 
wallonia.fr.fit.var <- factanal(covmat = wallonia.fr.tetrachoric.matrix, factors = wallonia.fr.Nfacs, rotation = "varimax") # varimax rotation 

# Print the factor analysis results, showing loadings greater than 0.3
print(wallonia.fr.fit.obl, digits = 5, cutoff = 0.3, sort = TRUE)

# Extract the factor loadings
wallonia.fr.efa.loads <- wallonia.fr.fit.obl$loadings

# Perform factor analysis using oblimin/varimax rotation again using fa
wallonia.fr.fit.obl.fa <- psych::fa(wallonia.fr.tetrachoric.matrix, nfactors = wallonia.fr.Nfacs, rotate = "oblimin") # oblimin rotation 

# Extract the factor loadings
wallonia.fr.efa.loads.fa <- wallonia.fr.fit.obl.fa$loadings

# Calculate the proportion of variance explained by each factor
# Sum of squared loadings for each factor (this represents the explained variance)
wallonia.fr.efa.ss <- apply(wallonia.fr.efa.loads.fa^2, 2, sum)

# The total variance is 1 for standardized data, so the proportion explained by each factor
wallonia.fr.efa.var <- wallonia.fr.efa.ss/length(wallonia.fr.fit.obl.fa$communality)

# Create a dataframe with the proportion variance for each factor
wallonia.fr.efa.var.df <- data.frame(Factor = paste0("F", 1:wallonia.fr.Nfacs), 
                               Proportion_Variance = wallonia.fr.efa.var)

# Write 'dataframe' dataframe to Excel
write_xlsx(wallonia.fr.efa.var.df, "files/wallonia_fr_efa_var_df.xlsx")

# Extract the inter-factor correlation matrix (Phi)
wallonia.fr.efa.inter <- wallonia.fr.fit.obl.fa$Phi

# Create a dataframe from the inter-factor correlation matrix
wallonia.fr.efa.inter.df <- data.frame(wallonia.fr.efa.inter)

# Move row names (which represent factors) into a new column called 'Factor'
wallonia.fr.efa.inter.df$Factor <- rownames(wallonia.fr.efa.inter.df)

# Replace "MR" with "F" in the Factor column (e.g., MR1 → F1)
wallonia.fr.efa.inter.df$Factor <- gsub("MR", "F", wallonia.fr.efa.inter.df$Factor)

# Also clean column names by removing ".MR" to keep only factor names (e.g., F.MR1 → F1)
colnames(wallonia.fr.efa.inter.df) <- gsub("\\.MR", "", colnames(wallonia.fr.efa.inter.df))

# Reshape the dataframe from wide to long format for pairwise correlations
wallonia.fr.efa.inter.df.long <- wallonia.fr.efa.inter.df %>%
  # Pivot all columns except 'Factor' into long format
  pivot_longer(cols = -Factor, names_to = "Other_Factor", values_to = "Correlation") %>%
  # Remove rows where a factor is correlated with itself (diagonal)
  filter(Factor != Other_Factor) %>%
  # Create a unique identifier for each pair (sorted alphabetically to avoid duplicates)
  mutate(pair = pmap_chr(list(Factor, Other_Factor), ~ paste(sort(c(..1, ..2)), collapse = "_"))) %>%
  # Keep only one row per unique factor pair
  distinct(pair, .keep_all = TRUE) %>%
  # Rename columns for clarity
  select(Factor1 = Factor, Factor2 = Other_Factor, Correlation)

# Ensure 'Factor2' labels are also cleaned (if still in MR format, though this may be redundant)
wallonia.fr.efa.inter.df.long$Factor2 <- gsub("MR", "F", wallonia.fr.efa.inter.df.long$Factor2)

# Remove rows where Factor1 and Factor2 are the same (i.e., self-correlations)
wallonia.fr.efa.inter.df.long <- wallonia.fr.efa.inter.df.long %>%
  filter(Factor1 != Factor2)

# Write 'wallonia.fr.efa.inter.df.long' dataframe to Excel
write_xlsx(wallonia.fr.efa.inter.df.long, "files/wallonia_fr_efa_inter_correlations.xlsx")

# Create a diagram of the factor loadings
fa.diagram(wallonia.fr.efa.loads)

# Transform factor loadings into a dataframe for easier analysis and manipulation
wallonia.fr.efa.loads.df <- as.data.frame.matrix(wallonia.fr.efa.loads)

# Transform row names (factor names) into a column
wallonia.fr.efa.loads.df <- rownames_to_column(wallonia.fr.efa.loads.df, var = "statements")

# Set values with absolute loadings <= 0.3 to NA for clarity
wallonia.fr.efa.loads.df[sapply(wallonia.fr.efa.loads.df, is.numeric)] <- lapply(wallonia.fr.efa.loads.df[sapply(wallonia.fr.efa.loads.df, is.numeric)], function(x) {
  x[abs(x) <= 0.3] <- NA
  return(x)
})

# Merge the factor loading data frame with another data frame containing labels for the statements
# This merges 'wallonia.fr.efa.loads.df' with 'labels.df' on the 'statements' column in 'wallonia.fr.efa.loads.df'
# and 'code' column in 'labels.df' to associate labels with factor loadings.
wallonia.fr.efa.loads.df <- merge(wallonia.fr.efa.loads.df, labels.df, by.x = "statements", by.y = "code")

# Select and organize necessary columns for further analysis and visualization
# Here we keep only the 'label' column and the three factors (Factor1 to Factor3) from the merged dataframe.
wallonia.fr.efa.loads.df <- wallonia.fr.efa.loads.df %>%
  select(label, Factor1, Factor2, Factor3)

# Create a LaTeX table of the factor loadings for reporting purposes
# This converts 'wallonia.fr.efa.loads.df' into a LaTeX-compatible table with a caption and label for referencing in a report.
wallonia.fr.efa.loads.table <- xtable(wallonia.fr.efa.loads.df, caption = "Factor Loadings", label = "tab1")

# Save the LaTeX table to a .tex file
sink("files/wallonia_fr_loads_table.tex")  # This redirects output to the file
print(wallonia.fr.efa.loads.table, type = "latex", comment = FALSE, include.rownames = FALSE)  # Prints the table in LaTeX format
sink()  # Turns off the sink function, so the output returns to the console

# Add a new column 'ids' that contains the row names of the data frame (useful for identifying rows)
wallonia.fr.efa.loads.df$ids <- rownames(wallonia.fr.efa.loads.df)

# Select relevant columns, including 'ids', 'label', and the factor columns, into a new data frame
wallonia.fr.factor.loads <- wallonia.fr.efa.loads.df[, c("ids", "label", "Factor1", "Factor2", "Factor3")]

# Melt the data from wide format to long format, which is necessary for ggplot to visualize the data
# This converts the factor loading data from multiple columns into a single 'variable' column and a 'value' column.
wallonia.fr.efa.loads.df <- reshape2::melt(wallonia.fr.factor.loads)

# Replace the string "Factor" with "F" in the 'variable' column for cleaner labeling in the plot
wallonia.fr.efa.loads.df$variable <- gsub("Factor", "F", wallonia.fr.efa.loads.df$variable)

wallonia.fr.efa.loads.df$ids <- as.factor(wallonia.fr.efa.loads.df$ids)
wallonia.fr.efa.loads.df$label <- as.factor(wallonia.fr.efa.loads.df$label)

# Merge wallonia.fr.efa.loads.df with labels.df
wallonia.fr.efa.loads.df <- merge(wallonia.fr.efa.loads.df, labels.df, by = "label")

# Add ideological leaning to statement labels
wallonia.fr.efa.loads.df <- wallonia.fr.efa.loads.df %>%
  mutate(
    new_label = paste0(ideology, " ", new_label)  
  )

# Create a png file to save the heatmap

# The resolution is set to 1200 dpi for high-quality output, and the image size is specified in inches (6x6).
png("figs/wallonia_fr_efa_loadings.png", units="in", width=7, height=6, res=1200)

# Sort the levels of the 'new_label' based on the substring starting from the 5th character
# Ensure there are no duplicate levels by using unique() before assigning the levels
wallonia.fr.efa.loads.df$new_label <- factor(wallonia.fr.efa.loads.df$new_label, 
                                       levels = unique(wallonia.fr.efa.loads.df$new_label[order(substr(wallonia.fr.efa.loads.df$new_label, 5, nchar(wallonia.fr.efa.loads.df$new_label)))]))

# Create the heatmap using ggplot2
# The 'x' axis represents the factors, 'y' represents the ids (statements),
# and 'fill' represents the factor loading values.
ggplot(wallonia.fr.efa.loads.df, aes(x = variable, y = new_label, fill = value)) + 
  geom_tile() +  # Create a tile-based heatmap
  geom_text(aes(label = ifelse(is.na(value), "", sprintf("%.2f", value))), size=2.5) + 
  scale_fill_gradient2(midpoint = 0, low = "#FFE338", high = "#FF0000", mid = "white", 
                       na.value = "lightgrey") +  # Color scale from yellow to red, with NA values in light grey
  labs(fill = "Loading") +  # Label for the color scale legend
  theme_minimal() +  # Apply a minimal theme for the plot
  scale_y_discrete(labels = function(y) {
    # Add color formatting
    y <- gsub("ECONOMY(?=\\.)", "<span style='color:#800000;'><b>ECONOMY</b></span>", y, perl = TRUE)  # Add color for ECFL
    y <- gsub("EDUCATION(?=\\.)", "<span style='color:#9A6324;'><b>EDUCATION</b></span>", y, perl = TRUE)  # Add color for EDUC
    y <- gsub("ENVIRONMENT(?=\\.)", "<span style='color:#3cb44b;'><b>ENVIRONMENT</b></span>", y, perl = TRUE)  # Add color for ENEG
    y <- gsub("ETHICS(?=\\.)", "<span style='color:#f58231;'><b>ETHICS</b></span>", y, perl = TRUE)  # Add color for ETHE
    y <- gsub("FOREIGN(?=\\.)", "<span style='color:#ffe119;'><b>FOREIGN</b></span>", y, perl = TRUE)  # Add color for FAED
    y <- gsub("WELFARE(?=\\.)", "<span style='color:#bfef45;'><b>WELFARE</b></span>", y, perl = TRUE)  # Add color for HSWF
    y <- gsub("IMMIGRATION(?=\\.)", "<span style='color:#e6194B;'><b>IMMIGRATION</b></span>", y, perl = TRUE)  # Add color for IMIN
    y <- gsub("CRIME(?=\\.)", "<span style='color:#42d4f4;'><b>CRIME</b></span>", y, perl = TRUE)  # Add color for JLEF
    y <- gsub("CULTURE(?=\\.)", "<span style='color:#f032e6;'><b>CULTURE</b></span>", y, perl = TRUE)  # Add color for MECU
    y <- gsub("MOBILITY(?=\\.)", "<span style='color:#4363d8;'><b>MOBILITY</b></span>", y, perl = TRUE)  # Add color for MPTR
    y <- gsub("HOUSING(?=\\.)", "<span style='color:#000075;'><b>HOUSING</b></span>", y, perl = TRUE)  # Add color for SPHO
    y <- gsub("STATE(?=\\.)", "<span style='color:#911eb4;'><b>STATE</b></span>", y, perl = TRUE)  # Add color for SRPI
    return(y)
  }) +
  theme(axis.text.y = element_markdown(),
        axis.text.x = element_text(hjust = .5),  # Center the x-axis labels
        axis.title = element_blank(),  # Remove axis titles
        legend.title = element_text(size = 9, margin = margin(r = 0.3, t = -1.8, unit = "lines")),  # Customize the legend title text size and margins
        legend.position = "bottom",  # Place the legend at the bottom
        legend.direction = "horizontal",  # Set the legend items to be horizontal
        legend.key.height = unit(0.4, "cm"), # Reduce the height of the legend scale
        legend.key.width = unit(.8, "cm")) # Increase the width of the legend scale

dev.off()  # Close the png file and save the plot

# Factor analysis diagram

png("figs/wallonia_fr_fa_diagram_g.png", units="in", width=15, height=12, res=1200)

wallonia.fr.fa.result <- psych::fa(wallonia.fr.tetrachoric.corr$rho, nfactors = 3, rotate = "oblimin")
colnames(wallonia.fr.fa.result$loadings) <- c("Factor 1", "Factor 2", "Factor 3")
fa.diagram(wallonia.fr.fa.result, simple = FALSE, cut = 0, cex = 1, l.cex = 1, digits = 2)

dev.off()

################################################################################
## ITEM RESPONSE THEORY
################################################################################

# Remove any rows with missing data from the dataset
# This ensures that the model estimation doesn't fail due to NA values
stemtest.wallonia.fr.df.complete <- stemtest.wallonia.fr.df.wgt[complete.cases(stemtest.wallonia.fr.df.wgt), ]

# Set seed
set.seed(123)

# Randomly sample 10,000 complete cases from the cleaned dataset
# This reduces the data size for quicker model estimation
stemtest.wallonia.fr.df.sample <- stemtest.wallonia.fr.df.complete[
  sample(nrow(stemtest.wallonia.fr.df.complete), 
         size = min(10000, nrow(stemtest.wallonia.fr.df.complete))), 
]

# Fit a unidimensional 2-Parameter Logistic (2PL) IRT model to the sample
# Assumes there is one underlying latent trait (dimension)
wallonia.fr.2PL.1D <- mirt(stemtest.wallonia.fr.df.sample[, !names(stemtest.wallonia.fr.df.sample) %in% "person_weights"],
                          model = 1, itemtype = '2PL', 
                          weights = stemtest.wallonia.fr.df.sample$person_weights)

summary(wallonia.fr.2PL.1D)

# Fit a bidimensional 2PL IRT model to the same sample
# Assumes two latent traits or factors influence item responses
wallonia.fr.2PL.2D <- mirt(stemtest.wallonia.fr.df.sample[, !names(stemtest.wallonia.fr.df.sample) %in% "person_weights"],
                          model = 2, itemtype = '2PL', 
                          weights = stemtest.wallonia.fr.df.sample$person_weights)

summary(wallonia.fr.2PL.2D)

# Fit a three-dimensional 2PL IRT model to the same sample
# Assumes two latent traits or factors influence item responses
wallonia.fr.2PL.3D <- mirt(stemtest.wallonia.fr.df.sample[, !names(stemtest.wallonia.fr.df.sample) %in% "person_weights"],
                          model = 3, itemtype = '2PL', 
                          weights = stemtest.wallonia.fr.df.sample$person_weights)

summary(wallonia.fr.2PL.3D)

# Fit a four-dimensional 2PL IRT model to the same sample
# Assumes two latent traits or factors influence item responses
wallonia.fr.2PL.4D <- mirt(stemtest.wallonia.fr.df.sample[, !names(stemtest.wallonia.fr.df.sample) %in% "person_weights"],
                          model = 4, itemtype = '2PL', 
                          weights = stemtest.wallonia.fr.df.sample$person_weights)

summary(wallonia.fr.2PL.4D)

# Compare the two models (1D vs. 2D) using a likelihood ratio test
# Helps determine whether the added complexity of a 2D model significantly improves fit
anova(wallonia.fr.2PL.1D, wallonia.fr.2PL.2D)

# Compare the two models (2D vs. 3D) using a likelihood ratio test
# Helps determine whether the added complexity of a 3D model significantly improves fit
anova(wallonia.fr.2PL.2D, wallonia.fr.2PL.3D)

# Compare the two models (3D vs. 4D) using a likelihood ratio test
# Helps determine whether the added complexity of a 4D model significantly improves fit
anova(wallonia.fr.2PL.3D, wallonia.fr.2PL.4D)

# Store IRT model summary in an object
wallonia.fr.2PL.3D.sum <- summary(wallonia.fr.2PL.3D)

# Extract the factor correlation matrix
wallonia.fr.2PL.3D.corr <- wallonia.fr.2PL.3D.sum$fcor

# Convert to dataframe
wallonia.fr.2PL.3D.corr.df <- as.data.frame(wallonia.fr.2PL.3D.corr)

# Convert to matrix if not already
wallonia.fr.2PL.3D.corr.mat <- as.matrix(wallonia.fr.2PL.3D.corr.df)

# Get the lower triangle indices (excluding diagonal)
wallonia.fr.2PL.3D.low.tri <- which(lower.tri(wallonia.fr.2PL.3D.corr.mat), arr.ind = TRUE)

# Create the long-format dataframe
wallonia.fr.2PL.3D.cor.pairs.df <- data.frame(
  vaa = "Wallonia",
  Factor1 = rownames(wallonia.fr.2PL.3D.corr.mat)[wallonia.fr.2PL.3D.low.tri[, 1]],
  Factor2 = colnames(wallonia.fr.2PL.3D.corr.mat)[wallonia.fr.2PL.3D.low.tri[, 2]],
  Correlation = wallonia.fr.2PL.3D.corr.mat[wallonia.fr.2PL.3D.low.tri]
)

# Save to Excel file
write_xlsx(wallonia.fr.2PL.3D.cor.pairs.df, "files/wallonia_fr_irt_inter_correlations.xlsx")

# Extract the factor loadings
wallonia.fr.irt.loads <- summary(wallonia.fr.2PL.3D)$rotF

# Calculate the proportion of variance explained by each factor
# Sum of squared loadings for each factor (this represents the explained variance)
wallonia.fr.irt.ss <- apply(wallonia.fr.irt.loads^2, 2, sum)

# The total variance is 1 for standardized data, so the proportion explained by each factor
wallonia.fr.irt.var <- wallonia.fr.irt.ss/nrow(wallonia.fr.irt.loads)

# Create a dataframe with the proportion variance for each factor
wallonia.fr.irt.var.df <- data.frame(Factor = paste0("F", 1:3), 
                               Proportion_Variance = wallonia.fr.irt.var)

# Write 'dataframe' dataframe to Excel
write_xlsx(wallonia.fr.irt.var.df, "files/wallonia_fr_irt_var_df.xlsx")

# Extract item parameters from the fitted multidimensional 2PL model
# Set IRTpars = TRUE to return discrimination (a) and difficulty (b) parameters
wallonia.fr.item.params <- coef(wallonia.fr.2PL.3D, IRTpars = TRUE, simplify = TRUE)

# Combine item-level parameter lists into a single data frame
# Remove the last element if it's the $Group (typically contains test-level info)
wallonia.fr.item.params.df <- do.call(rbind, wallonia.fr.item.params[-length(wallonia.fr.item.params)]) 
wallonia.fr.item.params.df <- as.data.frame(wallonia.fr.item.params.df)

# Add item names as a column (they're currently row names)
wallonia.fr.item.params.df$Item <- rownames(wallonia.fr.item.params.df)

# Step 1: Compute total discrimination (α)
# This is the euclidean norm of the a-vector across the three latent dimensions
# α = sqrt(a1^2 + a2^2 + a3^2), where a1–a3 are the item discriminations on each dimension
wallonia.fr.item.params.df$discrimination <- sqrt(wallonia.fr.item.params.df$a1^2 + wallonia.fr.item.params.df$a2^2 + wallonia.fr.item.params.df$a3^2)

# Step 2: Compute difficulty (b) for each item
# In multidimensional 2PL, difficulty is derived from the intercept (d) as:
# b = -d / α
# This gives a sense of how "hard" it is to agree with the item (i.e., threshold location)
wallonia.fr.item.params.df$b_calculated <- -wallonia.fr.item.params.df$d / wallonia.fr.item.params.df$discrimination

# Step 3: Clean the data
# Exclude any items where discrimination is missing or zero
# (This avoids divide-by-zero issues or meaningless points in the plot)
wallonia.fr.item.params.df.clean <- wallonia.fr.item.params.df[!is.na(wallonia.fr.item.params.df$discrimination) & wallonia.fr.item.params.df$discrimination > 0, ]

# Step 4: Plot item difficulty vs. discrimination
# Each point is an item; labels show the item name
# Higher discrimination = more informative item
# Higher difficulty = item requires higher latent trait level to agree with

png("figs/wallonia_fr_mirt_parameters.png", units = "in", width = 8, height = 6, res = 300)

ggplot(wallonia.fr.item.params.df.clean, aes(x = b_calculated, y = discrimination, label = rownames(wallonia.fr.item.params.df.clean))) +
  geom_point(color = "#0072B2", size = 3) +
  geom_text(vjust = -0.6, size = 4) +
  theme_minimal() +
  labs(
    # Removed the title
    x = "Difficulty (b)",
    y = "Discrimination (α)"
    #caption = "Computed from multidimensional 2PL IRT model"
  ) +
  theme(
    axis.title.x = element_text(size = 16, margin = margin(t = 12)),  # Top margin for x-axis title
    axis.title.y = element_text(size = 16, margin = margin(r = 12)),  # Right margin for y-axis title
    axis.text = element_text(size = 14),          # Larger axis tick labels
    plot.caption = element_text(size = 12),       # Optional: caption size
    panel.grid.minor = element_blank()
  )

dev.off()

# Extract factor loadings (discrimination parameters) from the 3-dimensional MIRT model
wallonia.fr.mirt.loads <- extract.mirt(wallonia.fr.2PL.3D, 'F')

# Convert the factor loadings matrix to a data frame for easier manipulation
wallonia.fr.mirt.loads.df <- as.data.frame(wallonia.fr.mirt.loads)

# Add item codes (original row names) as a new column called 'code'
wallonia.fr.mirt.loads.df$code <- rownames(wallonia.fr.mirt.loads.df)

# Reshape the data frame from wide to long format for plotting or analysis
# Each row now represents a loading for a specific item and dimension
wallonia.fr.mirt.loads.df <- reshape2::melt(wallonia.fr.mirt.loads.df)

# Set loadings with an absolute value ≤ 0.3 to NA
# This removes weak loadings for clarity in visualizations or further analysis
wallonia.fr.mirt.loads.df[sapply(wallonia.fr.mirt.loads.df, is.numeric)] <- lapply(
  wallonia.fr.mirt.loads.df[sapply(wallonia.fr.mirt.loads.df, is.numeric)],
  function(x) {
    x[abs(x) <= 0.3] <- NA
    return(x)
  }
)

# Merge the long-format factor loading data with an external label dataframe
# 'labels.df' must contain a 'code' column to match on
# This step adds descriptive item labels or metadata to the loadings
wallonia.fr.mirt.loads.df <- merge(wallonia.fr.mirt.loads.df, labels.df, by = "code")

# Add ideological leaning to statement labels
wallonia.fr.mirt.loads.df <- wallonia.fr.mirt.loads.df %>%
  mutate(
    new_label = paste0(ideology, " ", new_label)  
  )

# Create a png file to save the heatmap

# The resolution is set to 1200 dpi for high-quality output, and the image size is specified in inches (6x6).
png("figs/wallonia_fr_mirt_loadings.png", units="in", width=7, height=6, res=1200)

# Sort the levels of the 'new_label' based on the substring starting from the 5th character
# Ensure there are no duplicate levels by using unique() before assigning the levels
wallonia.fr.mirt.loads.df$new_label <- factor(wallonia.fr.mirt.loads.df$new_label, 
                                        levels = unique(wallonia.fr.mirt.loads.df$new_label[order(substr(wallonia.fr.mirt.loads.df$new_label, 5, nchar(wallonia.fr.mirt.loads.df$new_label)))]))

# Create the heatmap using ggplot2
# The 'x' axis represents the factors, 'y' represents the ids (statements),
# and 'fill' represents the factor loading values.
ggplot(wallonia.fr.mirt.loads.df, aes(x = variable, y = new_label, fill = value)) + 
  geom_tile() +  # Create a tile-based heatmap
  geom_text(aes(label = ifelse(is.na(value), "", sprintf("%.2f", value))), size=2.5) + 
  scale_fill_gradient2(midpoint = 0, low = "#FFE338", high = "#FF0000", mid = "white", 
                       na.value = "lightgrey") +  # Color scale from yellow to red, with NA values in light grey
  labs(fill = "Loading") +  # Label for the color scale legend
  theme_minimal() +  # Apply a minimal theme for the plot
  scale_y_discrete(labels = function(y) {
    # Add color formatting
    y <- gsub("ECONOMY(?=\\.)", "<span style='color:#800000;'><b>ECONOMY</b></span>", y, perl = TRUE)  # Add color for ECFL
    y <- gsub("EDUCATION(?=\\.)", "<span style='color:#9A6324;'><b>EDUCATION</b></span>", y, perl = TRUE)  # Add color for EDUC
    y <- gsub("ENVIRONMENT(?=\\.)", "<span style='color:#3cb44b;'><b>ENVIRONMENT</b></span>", y, perl = TRUE)  # Add color for ENEG
    y <- gsub("ETHICS(?=\\.)", "<span style='color:#f58231;'><b>ETHICS</b></span>", y, perl = TRUE)  # Add color for ETHE
    y <- gsub("FOREIGN(?=\\.)", "<span style='color:#ffe119;'><b>FOREIGN</b></span>", y, perl = TRUE)  # Add color for FAED
    y <- gsub("WELFARE(?=\\.)", "<span style='color:#bfef45;'><b>WELFARE</b></span>", y, perl = TRUE)  # Add color for HSWF
    y <- gsub("IMMIGRATION(?=\\.)", "<span style='color:#e6194B;'><b>IMMIGRATION</b></span>", y, perl = TRUE)  # Add color for IMIN
    y <- gsub("CRIME(?=\\.)", "<span style='color:#42d4f4;'><b>CRIME</b></span>", y, perl = TRUE)  # Add color for JLEF
    y <- gsub("CULTURE(?=\\.)", "<span style='color:#f032e6;'><b>CULTURE</b></span>", y, perl = TRUE)  # Add color for MECU
    y <- gsub("MOBILITY(?=\\.)", "<span style='color:#4363d8;'><b>MOBILITY</b></span>", y, perl = TRUE)  # Add color for MPTR
    y <- gsub("HOUSING(?=\\.)", "<span style='color:#000075;'><b>HOUSING</b></span>", y, perl = TRUE)  # Add color for SPHO
    y <- gsub("STATE(?=\\.)", "<span style='color:#911eb4;'><b>STATE</b></span>", y, perl = TRUE)  # Add color for SRPI
    return(y)
  }) +
  theme(axis.text.y = element_markdown(),
        axis.text.x = element_text(hjust = .5),  # Center the x-axis labels
        axis.title = element_blank(),  # Remove axis titles
        legend.title = element_text(size = 9, margin = margin(r = 0.3, t = -1.8, unit = "lines")),  # Customize the legend title text size and margins
        legend.position = "bottom",  # Place the legend at the bottom
        legend.direction = "horizontal",  # Set the legend items to be horizontal
        legend.key.height = unit(0.4, "cm"), # Reduce the height of the legend scale
        legend.key.width = unit(.8, "cm")) # Increase the width of the legend scale

dev.off()  # Close the png file and save the plot

# Select specific columns (code, variable, value, and new_label) from the 'wallonia.fr.efa.loads.df' dataframe
wallonia.fr.efa.loads.df <- wallonia.fr.efa.loads.df %>%
  dplyr::select(code, variable, value, new_label)

# Select specific columns (code, variable, value, and new_label) from the 'wallonia.fr.mirt.loads.df' dataframe
wallonia.fr.mirt.loads.df <- wallonia.fr.mirt.loads.df %>%
  dplyr::select(code, variable, value, new_label)

# Add a new column 'method' to the 'wallonia.fr.efa.loads.df' dataframe and assign the value "(a) Exploratory Factor Analysis" to it
wallonia.fr.efa.loads.df$method <- "(a) Exploratory Factor Analysis"

# Add a new column 'method' to the 'wallonia.fr.mirt.loads.df' dataframe and assign the value "(b) Item Response Theory" to it
wallonia.fr.mirt.loads.df$method <- "(b) Item Response Theory"

# Combine the two dataframes ('wallonia.fr.efa.loads.df' and 'wallonia.fr.mirt.loads.df') into one dataframe ('wallonia.fr.efa.loads.merged.df') by row-binding them
wallonia.fr.efa.loads.merged.df <- rbind(wallonia.fr.efa.loads.df, wallonia.fr.mirt.loads.df)

# Create a png file to save the heatmap

# The resolution is set to 1200 dpi for high-quality output, and the image size is specified in inches (6x6).
png("figs/wallonia_fr_loadings_combined.png", units="in", width=12, height=7, res=1200)

# Create the heatmap using ggplot2
# The 'x' axis represents the factors, 'y' represents the ids (statements),
# and 'fill' represents the factor loading values.
ggplot(wallonia.fr.efa.loads.merged.df, aes(x = variable, y = new_label, fill = value)) + 
  geom_tile() +  # Create a tile-based heatmap
  geom_text(aes(label = ifelse(is.na(value), "", sprintf("%.2f", value))), size=3.5) + 
  scale_fill_gradient2(midpoint = 0, low = "#FFE338", high = "#FF0000", mid = "white", 
                       na.value = "lightgrey") +  # Color scale from yellow to red, with NA values in light grey
  labs(fill = "Loading") +  # Label for the color scale legend
  theme_minimal() +  # Apply a minimal theme for the plot
  facet_wrap(~ method) +
  scale_y_discrete(labels = function(y) {
    # Add color formatting
    y <- gsub("ECONOMY(?=\\.)", "<span style='color:#800000;'><b>ECONOMY</b></span>", y, perl = TRUE)  # Add color for ECFL
    y <- gsub("EDUCATION(?=\\.)", "<span style='color:#9A6324;'><b>EDUCATION</b></span>", y, perl = TRUE)  # Add color for EDUC
    y <- gsub("ENVIRONMENT(?=\\.)", "<span style='color:#3cb44b;'><b>ENVIRONMENT</b></span>", y, perl = TRUE)  # Add color for ENEG
    y <- gsub("ETHICS(?=\\.)", "<span style='color:#f58231;'><b>ETHICS</b></span>", y, perl = TRUE)  # Add color for ETHE
    y <- gsub("FOREIGN(?=\\.)", "<span style='color:#ffe119;'><b>FOREIGN</b></span>", y, perl = TRUE)  # Add color for FAED
    y <- gsub("WELFARE(?=\\.)", "<span style='color:#bfef45;'><b>WELFARE</b></span>", y, perl = TRUE)  # Add color for HSWF
    y <- gsub("IMMIGRATION(?=\\.)", "<span style='color:#e6194B;'><b>IMMIGRATION</b></span>", y, perl = TRUE)  # Add color for IMIN
    y <- gsub("CRIME(?=\\.)", "<span style='color:#42d4f4;'><b>CRIME</b></span>", y, perl = TRUE)  # Add color for JLEF
    y <- gsub("CULTURE(?=\\.)", "<span style='color:#f032e6;'><b>CULTURE</b></span>", y, perl = TRUE)  # Add color for MECU
    y <- gsub("MOBILITY(?=\\.)", "<span style='color:#4363d8;'><b>MOBILITY</b></span>", y, perl = TRUE)  # Add color for MPTR
    y <- gsub("HOUSING(?=\\.)", "<span style='color:#000075;'><b>HOUSING</b></span>", y, perl = TRUE)  # Add color for SPHO
    y <- gsub("STATE(?=\\.)", "<span style='color:#911eb4;'><b>STATE</b></span>", y, perl = TRUE)  # Add color for SRPI
    return(y)
  }) +
  theme(axis.text.y = element_markdown(size=12),
        axis.text.x = element_text(size=12, hjust = .5),  # Center the x-axis labels
        axis.title = element_blank(),  # Remove axis titles
        legend.title = element_text(size = 12, margin = margin(r = 0.3, t = -1.8, unit = "lines")),  # Customize the legend title text size and margins
        legend.text = element_text(size = 12),
        legend.position = "bottom",  # Place the legend at the bottom
        legend.direction = "horizontal",  # Set the legend items to be horizontal
        legend.key.height = unit(0.4, "cm"), # Reduce the height of the legend scale
        legend.key.width = unit(.8, "cm"), # Increase the width of the legend scale
        strip.text = element_text(size = 14))  # Adjust the facet title size here

dev.off()  # Close the png file and save the plot

################################################################################
## CHECK IRT MODELS IMPROVEMENTS
################################################################################

set.seed(1234)  # For reproducibility

# -------------------------
# 1. Split data
# -------------------------

n <- nrow(stemtest.wallonia.fr.df.sample)
wallonia.fr.train.index <- sample(seq_len(n), size = floor(0.8 * n))

wallonia.fr.train.data <- stemtest.wallonia.fr.df.sample[wallonia.fr.train.index, ]
wallonia.fr.test.data  <- stemtest.wallonia.fr.df.sample[-wallonia.fr.train.index, ]

# -------------------------
# 2. Prepare test data
# -------------------------

wallonia.fr.test.items <- wallonia.fr.test.data[, !names(wallonia.fr.test.data) %in% "person_weights"]
wallonia.fr.test.weights <- wallonia.fr.test.data$person_weights

# -------------------------
# 3. Fit 2PL models on test data
# -------------------------

wallonia.fr.2PL.1D.test <- mirt(wallonia.fr.test.items, model = 1, itemtype = "2PL",
                             weights = wallonia.fr.test.weights, verbose = FALSE)

wallonia.fr.2PL.2D.test <- mirt(wallonia.fr.test.items, model = 2, itemtype = "2PL",
                             weights = wallonia.fr.test.weights, verbose = FALSE)

wallonia.fr.2PL.3D.test <- mirt(wallonia.fr.test.items, model = 3, itemtype = "2PL",
                             weights = wallonia.fr.test.weights, verbose = FALSE)

wallonia.fr.2PL.4D.test <- mirt(wallonia.fr.test.items, model = 4, itemtype = "2PL",
                             weights = wallonia.fr.test.weights, verbose = FALSE)

# -------------------------
# 4. Define safe extraction functions
# -------------------------

# Safe log-likelihood extraction
safe_logLik <- function(model) {
  out <- tryCatch(logLik(model), error = function(e) NA_real_)
  if (length(out) == 0) return(NA_real_) else return(as.numeric(out))
}

# Extract BIC directly from the internal slot
safe_BIC <- function(model) {
  out <- tryCatch(model@Fit$BIC, error = function(e) NA_real_)
  if (length(out) == 0) return(NA_real_) else return(as.numeric(out))
}

# -------------------------
# 5. Extract logLik & BIC for each model
# -------------------------

wallonia.fr.logliks <- c(
  safe_logLik(wallonia.fr.2PL.1D.test),
  safe_logLik(wallonia.fr.2PL.2D.test),
  safe_logLik(wallonia.fr.2PL.3D.test),
  safe_logLik(wallonia.fr.2PL.4D.test)
)

wallonia.fr.bics <- c(
  safe_BIC(wallonia.fr.2PL.1D.test),
  safe_BIC(wallonia.fr.2PL.2D.test),
  safe_BIC(wallonia.fr.2PL.3D.test),
  safe_BIC(wallonia.fr.2PL.4D.test)
)

# -------------------------
# 6. Create data.frame with model fit stats
# -------------------------

wallonia.fr.irt.fit.stats <- data.frame(
  Model = c("2PL_1D", "2PL_2D", "2PL_3D", "2PL_4D"),
  Dimension = 1:4,
  LogLikelihood = wallonia.fr.logliks,
  BIC = wallonia.fr.bics
)

# -------------------------
# 7. Fit structureless baseline model (intercept-only GLMs)
# -------------------------

baseline_models <- lapply(wallonia.fr.test.items, function(item) {
  glm(item ~ 1, family = binomial(link = "logit"))
})

baseline_logLik <- sum(sapply(baseline_models, function(m) as.numeric(logLik(m))))
baseline_BIC <- sum(sapply(baseline_models, BIC))

# Add baseline row
wallonia.fr.irt.fit.stats <- rbind(
  data.frame(
    Model = "NoStructure_Baseline",
    Dimension = 0,
    LogLikelihood = baseline_logLik,
    BIC = baseline_BIC
  ),
  wallonia.fr.irt.fit.stats
)

# -------------------------
# 8. Compute improvements
# -------------------------

# Sort by number of dimensions
wallonia.fr.irt.fit.stats <- wallonia.fr.irt.fit.stats[order(wallonia.fr.irt.fit.stats$Dimension), ]

# Differences vs. null (absolute improvement)
wallonia.fr.irt.fit.stats$LogLik_vs_Null <- wallonia.fr.irt.fit.stats$LogLikelihood - baseline_logLik
wallonia.fr.irt.fit.stats$BIC_vs_Null <- wallonia.fr.irt.fit.stats$BIC - baseline_BIC

# Differences vs. previous model (incremental improvement)
wallonia.fr.irt.fit.stats$LogLik_vs_Prev <- c(NA, diff(wallonia.fr.irt.fit.stats$LogLikelihood))
wallonia.fr.irt.fit.stats$BIC_vs_Prev <- c(NA, diff(wallonia.fr.irt.fit.stats$BIC))

# -------------------------
# 9. Display results and diagnostics
# -------------------------

print(wallonia.fr.irt.fit.stats)
print(xtable(wallonia.fr.irt.fit.stats), type = "latex", include.rownames = FALSE)

# Check which models were extracted successfully
model_status <- data.frame(
  Model = wallonia.fr.irt.fit.stats$Model,
  LogLik_OK = !is.na(wallonia.fr.irt.fit.stats$LogLikelihood),
  BIC_OK = !is.na(wallonia.fr.irt.fit.stats$BIC)
)

print(model_status)